Реализация барьера в Java

Question

Как можно реализовать барьер с семафорами в Java. Будет ли работать следующий псевдокод? Как это может быть написано с использованием Java-класса Semaphore.

N - количество нитей, которые нужно ждать у барьера. EveryoneHasReachedBarrier - условная переменная.

Aquire(mutex) 
m = m + 1; 
if(m != N) 
{ 
    Release(mutex); 
    Aquire(EveryoneHasReachedBarrier); 
} 
else 
{ 
    m = 0; 
    Release(mutex); 
    for(i=0; i<N; i++) 
    { 
     Release(EveryoneHasReachedBarrier); 
    } 
} 

Answer 1

1) Ваш псевдокод не использует семафоры, поэтому он не является решением.

2) Это не соответствует тому, как работает примитивный mutex Java/wait/notify.

3) Возможно, это не сработает. Поскольку вы освобождаете мьютекс, прежде чем приобретать условие, существует вероятность состояния гонки. (Не совсем ясно, что это так, потому что семантика ваших «примитивов» открыта для интерпретации.)

Подсказка: вам нужно внимательно прочитать javadocs для класса Semaphore, а затем попытаться отобразить их на проблему, которую вы пытаетесь решить.

Answer 2

Просто использовать CountDownLatch или CyclicBarrier.