Java多线程CyclicBarrier的实现代码

//构造器1
public CyclicBarrier(int parties, Runnable barrierAction) {
  if (parties <= 0) throw new IllegalArgumentException();
  this.parties = parties;
  this.count = parties;
  this.barrierCommand = barrierAction;
}
 
//构造器2
public CyclicBarrier(int parties) {
  this(parties, null);
}

//非定时等待 (比如指定3个线程 每一个线程调用一次内部count--  当count==0时 释放3个线程 然后count重置为3  )
public int await() throws InterruptedException, BrokenBarrierException {
  try {
    return dowait(false, 0L);
  } catch (TimeoutException toe) {
    throw new Error(toe);
  }
}
 
//定时等待 (就是子一定时间内如果还没有 到时间自动唤醒)
public int await(long timeout, TimeUnit unit) throws InterruptedException, BrokenBarrierException, TimeoutException {
  return dowait(true, unit.toNanos(timeout));
}

public void reset() {
        final ReentrantLock lock = this.lock;
        lock.lock();
        try {
            breakBarrier();   // break the current generation
            nextGeneration(); // start a new generation
        } finally {
            lock.unlock();
        }
    }

public static void main(String[] args) throws InterruptedException {

        //设置这局游戏的唯一id 和人数
        CyclicBarrierUtils.initialize("da1",10,()->{
            System.out.println("10人都加载完毕,进入游戏");
        });
        //开始加载游戏
        for (int i = 0; i < 10; i++) {
            int finalI = i;
            ExecutorUtils.create(()->{
                System.out.println(finalI +":加载完毕,等待其他人....");
                CyclicBarrierUtils.await("da1");
            });
        }
    }