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()。很难说，因为不清楚您要实现什么。