//構造器，定義參與的線程數
CyclicBarrier cyclicBarrier = new CyclicBarrier(10);
//構造器，可以傳入跳柵后需要執(zhí)行的線程
public CyclicBarrier(int parties, Runnable barrierAction);
//將屏障重置為其初始狀態(tài)
void reset()
//進行等待
int await()
//進行等待，同時具備超時時間
public int await(long timeout, TimeUnit unit)

public class CyclicBarrierRunnable implements Runnable{
    private CyclicBarrier cyclicBarrier;
    private int number;
    public CyclicBarrierRunnable(CyclicBarrier cyclicBarrier, int number) {
        this.cyclicBarrier = cyclicBarrier;
        this.number = number;
    }
    @Override
    public void run() {
        System.out.println("玩家" + number + "號正在加載游戲...");
        try {
            TimeUnit.SECONDS.sleep(2);
            cyclicBarrier.await();
        } catch (Exception e) {
            System.out.println("線程執(zhí)行出現問題");
        }
        System.out.println("玩家" + number + "號加載完成。");
    }
}

public class Main {
    public static void main(String[] args) throws InterruptedException, BrokenBarrierException {
        CyclicBarrier cyclicBarrier = new CyclicBarrier(10);
        //獲取參與方的總數
        System.out.println("參與方的總數為：" + cyclicBarrier.getParties());
        //獲取此時等待的線程數
        System.out.println("此時等待的線程數為：" + cyclicBarrier.getNumberWaiting());
        for (int i = 0; i < 10; i++){
            CyclicBarrierRunnable runnable = new CyclicBarrierRunnable(cyclicBarrier, i);
            new Thread(runnable).start();
        }
    }
}