可重置倒计时闩锁

问题描述

我有一个问题想要解决。我有一个线程必须等待多个可变数量的异步线程来完成它们的执行，然后它必须执行并再次保持等待状态，直到其他线程完成它们的执行。

示例：

线程 A 等待线程 B 和 C 完成它们的执行。之后，必须执行线程 A，其他线程应等待。这是一个重复n次的循环。

ThreadA{
   public void run(){
      while(true){
         if(queue.peek() % 2 == 0){
            phaser.arriveAndAwaitAdvance();
            doStuff();
         }
      }
   }
}
ThreadB{
   public void run(){
      while(true){
          if(queue.peek() % 2 == 0){
             doStuff();
             phaser.arrive();
          }
      }
   }
}

线程 C 的伪代码与线程 B 相同。

我需要这样的同步：线程 A 必须在线程 B 和线程 C 执行之后才执行，线程 B 和线程 C 必须等待线程 A 完成执行。

我尝试使用 Phaser，如上面代码中提到的 Phaser，但没有得到预期的结果。

谁能举个例子？

我正在使用 Java 8，我正在寻找一种可重置形式的 CountDownLatch，可能使用移相器。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）