Java中CyclicBarrier线程协调方法

import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {
    public static void main(String[] args) {
        int threadCount = 5;
        CyclicBarrier barrier = new CyclicBarrier(threadCount, () -> {
            System.out.println("所有线程已就位，比赛开始！");
        });

        for (int i = 0; i < threadCount; i++) {
            new Thread(new Worker(barrier)).start();
        }
    }

    static class Worker implements Runnable {
        private final CyclicBarrier barrier;

        Worker(CyclicBarrier barrier) {
            this.barrier = barrier;
        }

        @Override
        public void run() {
            try {
                System.out.println(Thread.currentThread().getName() + " 准备就绪...");
                barrier.await(); // 等待其他线程
                System.out.println(Thread.currentThread().getName() + " 开始执行任务。");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

CyclicBarrier stageBarrier = new CyclicBarrier(3);

Runnable task = () -> {
    try {
        System.out.println("第一阶段：" + Thread.currentThread().getName());
        // 第一阶段工作
        Thread.sleep(1000);
        stageBarrier.await();

        System.out.println("第二阶段：" + Thread.currentThread().getName());
        // 第二阶段工作
        Thread.sleep(1000);
        stageBarrier.await();

        System.out.println("第三阶段：" + Thread.currentThread().getName());
    } catch (Exception e) {
        e.printStackTrace();
    }
};

for (int i = 0; i < 3; i++) {
    new Thread(task).start();
}