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

//非定時(shí)等待 (比如指定3個(gè)線程 每一個(gè)線程調(diào)用一次內(nèi)部count--  當(dāng)count==0時(shí) 釋放3個(gè)線程 然后count重置為3  )
public int await() throws InterruptedException, BrokenBarrierException {
  try {
    return dowait(false, 0L);
  } catch (TimeoutException toe) {
    throw new Error(toe);
  }
}
 
//定時(shí)等待 (就是子一定時(shí)間內(nèi)如果還沒有 到時(shí)間自動(dòng)喚醒)
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 {

        //設(shè)置這局游戲的唯一id 和人數(shù)
        CyclicBarrierUtils.initialize("da1",10,()->{
            System.out.println("10人都加載完畢,進(jìn)入游戲");
        });
        //開始加載游戲
        for (int i = 0; i < 10; i++) {
            int finalI = i;
            ExecutorUtils.create(()->{
                System.out.println(finalI +":加載完畢,等待其他人....");
                CyclicBarrierUtils.await("da1");
            });
        }
    }