Java多线程中CyclicBarrier的作用

CyclicBarrier 是 Java 并发包 java.util.concurrent 中的一个同步辅助类，它允许一组线程互相等待，直到所有线程都准备好继续执行。CyclicBarrier 特别适用于那些需要多个线程协同工作，且每个线程在继续执行之前必须等待其他线程达到某个屏障点的场景。

主要特点

1. 可重用性：与 CountDownLatch 不同，CyclicBarrier 可以被重用。一旦所有线程都到达屏障点，屏障可以重置并用于下一轮的同步。
2. 灵活性：CyclicBarrier 允许在所有线程到达屏障点后执行一个特定的任务（通过构造函数中的 Runnable 参数）。
3. 线程等待：当一个线程到达屏障点时，它会进入等待状态，直到所有其他线程也都到达屏障点。

使用场景

• 并行计算：将一个大任务拆分成多个小任务，并行执行这些小任务，最后汇总结果。
• 数据聚合：从多个数据源收集数据，并在所有数据都准备好后进行处理。
• 资源初始化：确保所有必要的资源在应用程序启动之前都已初始化。

示例代码

以下是一个简单的 CyclicBarrier 示例，模拟了三个线程互相等待的场景：

import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {

    public static void main(String[] args) {
        // 创建一个 CyclicBarrier，指定参与同步的线程数和屏障动作
        CyclicBarrier barrier = new CyclicBarrier(3, () -> System.out.println("所有线程都已到达屏障点！"));

        // 创建并启动三个线程
        for (int i = 0; i < 3; i++) {
            new Thread(new Worker(barrier), "Thread-" + i).start();
        }
    }

    static class Worker implements Runnable {
        private final CyclicBarrier barrier;

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

        @Override
        public void run() {
            try {
                System.out.println(Thread.currentThread().getName() + " 正在执行任务...");
                // 模拟任务执行时间
                Thread.sleep((long) (Math.random() * 1000));
                System.out.println(Thread.currentThread().getName() + " 已完成任务，等待其他线程...");

                // 等待其他线程到达屏障点
                barrier.await();

                System.out.println(Thread.currentThread().getName() + " 继续执行后续任务...");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

在这个示例中，我们创建了一个 CyclicBarrier，指定参与同步的线程数为 3，并提供了一个屏障动作，当所有线程都到达屏障点时执行。然后，我们创建并启动了三个线程，每个线程在执行完任务后会调用 barrier.await() 方法等待其他线程。当所有线程都到达屏障点后，屏障动作会被执行，然后所有线程继续执行后续任务。