Java多线程——等待条件和释放所有线程

Question

我有一个相对简单的问题要解决，即我想让所有线程等待某个条件发生然后继续。可以用下面的代码来解释:

void doSth(){ //shared by multiple threads
...
if(!conditionMet())
    await();

//procceed further
resetCondition()
}

我不想使用锁定和条件，因为它似乎没有必要。 CountDownLatch 会很完美，但我必须重置闩锁，而且 CyclicBarrier 也不起作用，因为我不知道有多少线程需要调用 await。此外，当信号被发送到等待线程时，它们都应该被释放并继续。你们会如何处理这个问题？

Answer 1

我推荐Phaser

I have no idea how many threads need to call await.

对于每个最终需要等待的线程，调用 phaser.register() [register 不等待，它告诉 phaser 期望另一个线程等待或触发屏障]

CountDownLatch would be perfect, but I have to reset the latch

线程完成后，调用 phaser.arriveAndAwaitAdvance()。那时，所有线程都将在那里等待，直到 number of threads registered == number of threads arrived。