CyclicBarrier是Java中用于多线程在屏障点同步的工具，当指定数量的线程都调用await()后，所有线程被释放继续执行，且可重复使用；常用于并行计算、性能测试等场景，支持屏障动作和异常处理，通过reset()可重置状态。
在Java中，CyclicBarrier 是一个同步工具，用于让一组线程在执行到某个共同的屏障点时相互等待，直到所有线程都到达该点后，再一起继续执行。它特别适用于多线程协作完成阶段性任务的场景，比如并行计算中的分阶段处理。
什么是CyclicBarrier？
CyclicBarrier 允许指定数量的线程在执行过程中互相等待，当所有线程都调用了 await() 方法后，这些线程才会同时被释放，继续执行后续操作。这个“屏障”可以被重复使用，因此称为“循环的”（cyclic）。
构造方法如下：
CyclicBarrier(int parties)CyclicBarrier(int parties, Runnable barrierAction)
其中，parties 表示需要等待的线程数量；第二个构造函数还可以传入一个 Runnable 任务，该任务会在所有线程都到达屏障点后、被释放前执行一次。
基本使用示例
以下是一个简单的例子，展示4个线程协同工作，每个线程执行一部分任务，然后在屏障处等待，全部到达后再继续：
import java.util.concurrent.CyclicBarrier;public class CyclicBarrierExample {
public static void main(String[] args) {
int threadCount = 4;
CyclicBarrier barrier = new CyclicBarrier(threadCount, () -> {
System.out.println("✅ 所有线程已就位，开始下一阶段！");
});
for (int i = 1; i
new Thread(() -> {
try {
System.out.println(Thread.currentThread().getName() + " 正在执行第一阶段任务...");
Thread.sleep((long)(Math.random() * 2000)); // 模拟耗时
System.out.println(Thread.currentThread().getName() + " 到达屏障点，等待其他线程...");
barrier.await(); // 等待其他线程
System.out.println(Thread.currentThread().getName() + " 继续执行第二阶段任务...");
} catch (Exception e) {
e.printStackTrace();
}
}).start();
}
}
}
输出可能类似：
Thread-0 正在执行第一阶段任务...Thread-2 正在执行第一阶段任务...
Thread-1 正在执行第一阶段任务...
Thread-3 正在执行第一阶段任务...
Thread-2 到达屏障点，等待其他线程...
Thread-0 到达屏障点，等待其他线程...
Thread-1 到达屏障点，等待其他线程...
Thread-3 到达屏障点，等待其他线程...
✅ 所有线程已就位，开始下一阶段！
Thread-3 继续执行第二阶段任务...
Thread-1 继续执行第二阶段任务...
Thread-0 继续执行第二阶段任务...
Thread-2 继续执行第二阶段任务...
常见应用场景
CyclicBarrier 在实际开发中有多种用途：
- 并行计算分阶段同步：多个线程分别处理数据块，在每阶段结束时同步，确保所有部分都完成后再进入下一阶段。
- 性能测试：让多个线程同时开始执行任务，以测试并发性能。
- 游戏或模拟系统启动：所有玩家或模块准备就绪后，统一进入游戏状态。
注意事项与异常处理
使用 CyclicBarrier 时需要注意：
- 如果某个线程在等待期间被中断，会抛出 InterruptedException，其他正在等待的线程会收到 BrokenBarrierException，表示屏障已被破坏。
- 避免长时间阻塞在 await() 中，必要时可使用带超时的版本：await(long timeout, TimeUnit unit)。
- 一旦屏障被打破（例如某个线程中断），需要重新创建 CyclicBarrier 实例或调用 reset() 方法重置（注意 reset() 会影响正在等待的线程）。
基本上就这些。CyclicBarrier 使用简单，适合需要阶段性同步的多线程协作场景，合理使用能有效提升程序的协调性和可读性。
