IllegalMonitorStateException - CyclicBarrier

Question

У меня есть метод, который использует CyclicBarrier, как показано ниже:

public void getMessage(Message obj){
    CyclicBarrier barrier = new CyclicBarrier(1, new Runnable() {
        @Override
        public void run() {
            synchronized(obj){ 
                System.out.println("--The End --");
            }
        }
    });

    executor.execute(new Runnable() {
        @Override
        public void run() {
            synchronized(obj){
                //Perform some routine with message object
            }
            try {
                barrier.wait();//java.lang.IllegalMonitorStateException thrown on this line
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    });
}

В тот момент, когда я жду, пока подпрограмма завершит выполнение, я получаю:

Exception in thread "pool-2-thread-3"
java.lang.IllegalMonitorStateException
    at java.lang.Object.wait(Native Method)
    at java.lang.Object.wait(Object.java:502)

Кто-нибудь знает, что я здесь не так делаю?

Answer 1

Чтобы вызвать wait() для любого объекта, текущий поток должен иметь свой монитор.Вы звоните barrier.wait() без каких-либо synchronized(barrier).

Однако вы, возможно, хотели использовать метод await() (в CyclicBarrier) вместо wait().Трудно сказать, поскольку неясно, чего вы пытаетесь достичь.

Answer 2

Циклический барьер не предназначен для использования, как вы делаете здесь: ожидается, что участвующие потоки вызовут блокирующий метод "await ()".

В качестве примечания, CyclicBarrier со счетчиком 1 равенсовершенно бесполезно: его цель - позволить определенному количеству потоков (количество барьеров) ждать друг друга, прежде чем продолжить.Может быть, вам стоит подумать об изменении всего алгоритма, особенно если вы не уверены, как работает параллелизм.

Answer 3

Вам необходимо получить замок перед использованием объекта барьера.

С уважением, Дхирадж Джоши

Answer 4

Может быть, вы хотите использовать await() вместо этого wait()?

wait, чтобы блокировать поток над определенным объектом, и это особенность каждого объекта, но в вашем случаеВы называете это, не беря монитор этого.Вы должны вызывать wait из того же объекта или использовать блок synchronized над barrier.

Answer 5

да, вам нужно получить монитор барьера следующим образом:

synchhronized(barrier){
try {
     barrier.wait();//java.lang.IllegalMonitorStateException not thrown on this line
    } catch (InterruptedException e) {
    e.printStackTrace();
}
}