Java并发-离开方法后重置条件

Question

我正在尝试找出以下问题的解决方案:

public void signal(){
   //resets condition and signals threads blocked below
}

public void getValue(){

    waitOnCondition(); //block if a condition is not met. When signalled, all threads should proceed and get the value

    //get value

    resetCondition(); //reset condition, so that the next thread that executes this method blocks on the method above

}

我面临的问题似乎很简单，但我正在努力了解如何捕获所有边缘情况。

一种解决方案可能是将Lock与Condition一起使用，然后所有在waitOnCondition上运行的线程都将await<例如， 直到标志设置为 true，然后继续。然后，执行 signal() 的线程将使用相同的锁，将标志设置为 true 并设置 signal。然后，被释放的线程将重新获取锁以将条件设​​置为 false。然而，这并不能保证所有线程都会到达 getValue 点。例如:

线程1和2正在等待，获取信号。收到信号后，线程 1 重新获取锁，检查条件(现在为真)，然后继续。获取值，获取锁并将条件设置为 false。线程 2 现在发现条件仍然为 false，并再次阻塞。

另一个非常简洁优雅的解决方案是使用 CountDownLatch。这保证了所有线程都会继续进行。然而，这是不可重置的。还有其他想法或意见吗？

Answer 1

看起来像CyclicBarrier就是你所需要的。它是可重置的，并且还允许在所有各方都在场时触发屏障操作。

还有Phaser这是 CyclicBarrier 的高级版本，需要 JDK 7 才能运行。