Многопоточная программа не работает должным образомJAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Многопоточная программа не работает должным образом

Сообщение Anonymous »

Я пытался узнать о семафорах, читая «Маленькую книгу семафоров».
В этом есть загадка
Обобщите решение встречи. Каждый поток должен выполнять
следующий код:
1 rendezvous
2 critical point

Требование синхронизации заключается в том, что ни один поток не выполняет критическую точку до тех пор, пока все потоки не выполнят рандеву.
Вы можете предположить, что существует n потоков и что это значение хранится в переменной , n, который доступен из всех потоков.
Когда прибывают первые n - 1 потоков, они должны блокироваться до тех пор, пока не прибудет n-й поток, после чего все потоки могут продолжить работу
Кажется, мое решение работает только иногда, а в других случаях оно зависает после печати всех встреч и некоторых, но не всех критических точек.
Я не могу понять, в чем здесь проблема
Вот мое решение кода -
import java.util.concurrent.*;
import java.util.List;
import java.util.ArrayList;

class Main {

private static final int n = 10;
private static int counter = 0;
private static final Semaphore mutex = new Semaphore(1);
private static final Semaphore barrier = new Semaphore(0);

private static class Runner implements Runnable {

@Override
public void run() {
try {
System.out.println("Rendezvous");
mutex.acquire();
counter = counter + 1;
mutex.release();
while (counter < n);
barrier.release();
barrier.acquire();
System.out.println("Critical Section");
barrier.release();
} catch (InterruptedException ex) {
System.out.println("Got exception while executing code for runner : " + ex.getMessage());
}
}
}

public static void main(String[] args) {
List threads = new ArrayList();
for (int i = 0;i < n;i++) {
Thread t = new Thread(new Runner());
t.start();
threads.add(t);
}

for (Thread t : threads) {
try {
t.join();
} catch (InterruptedException ex) {
System.out.println("Got exception while executing code for runner : " + ex.getMessage());
}
}

System.out.println("Completed");
}
}


Подробнее здесь: https://stackoverflow.com/questions/787 ... s-expected
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»