CyclicBarrier是Java中可重复使用的同步工具，用于让一组线程互相等待直至全部到达屏障点后同时继续执行。其核心功能通过await()方法实现，当指定数量的线程都调用了await()后，屏障解除并可触发预设的Runnable任务。与CountDownLatch不同，CyclicBarrier支持重复使用，适用于并行计算、批量数据处理、游戏同步启动、性能测试等需要多线程协同的场景。使用时需注意避免因线程中断导致屏障断裂（broken），可通过isBroken()检测状态，并建议设置超时机制防止无限等待。构造方法包括CyclicBarrier(int parties)和CyclicBarrier(int parties, Runnable barrierAction)，后者在所有线程到达后优先执行指定任务。示例中4个线程模拟运动员准备就绪后统一出发，验证了其同步能力。总之，CyclicBarrier提供了一种高效、简洁的线程协作机制，特别适合“齐头并进”式的周期性同步需求。
在Java多线程编程中，CyclicBarrier 是一个非常实用的同步工具，用于让一组线程相互等待，直到所有线程都到达某个公共屏障点后再继续执行。它特别适用于需要多个线程协同完成某项任务的场景，比如并行计算、批量数据处理等。
什么是CyclicBarrier
CyclicBarrier 字面意思是“循环栅栏”，它可以实现线程间的相互等待。当指定数量的线程都调用了 await() 方法后，这些线程才会同时被释放，继续执行后续逻辑。与 CountDownLatch 不同的是，CyclicBarrier 是可重复使用的——一旦所有线程通过屏障，它就可以被重置并再次使用。
构造方法如下：
-
CyclicBarrier(int parties)：创建一个包含指定数量参与线程的屏障。 -
CyclicBarrier(int parties, Runnable barrierAction)：在所有线程到达屏障后，优先执行 barrierAction 指定的任务。
基本使用示例
下面是一个简单的例子，模拟4个线程协作完成任务，在全部准备就绪后统一出发：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.CyclicBarrier;
<p>public class CyclicBarrierDemo {
public static void main(String[] args) {
int threadCount = 4;
CyclicBarrier barrier = new CyclicBarrier(threadCount, () -> {
System.out.println("所有运动员已就位，发令枪响，比赛开始！");
});</p><pre class="brush:php;toolbar:false;"> for (int i = 1; i <= threadCount; i++) {
new Thread(() -> {
try {
String threadName = Thread.currentThread().getName();
System.out.println(threadName + " 正在准备...");
Thread.sleep((long) (Math.random() * 3000)); // 模拟准备时间
System.out.println(threadName + " 准备完成，等待其他线程...");
barrier.await(); // 等待所有线程到达
System.out.println(threadName + " 开始执行任务！");
} catch (Exception e) {
e.printStackTrace();
}
}, "运动员-" + i).start();
}
}}
输出结果类似：
运动员-1 正在准备... 运动员-2 正在准备... 运动员-3 正在准备... 运动员-4 正在准备... 运动员-2 准备完成，等待其他线程... 运动员-1 准备完成，等待其他线程... 运动员-4 准备完成，等待其他线程... 运动员-3 准备完成，等待其他线程... 所有运动员已就位，发令枪响，比赛开始！ 运动员-3 开始执行任务！ 运动员-1 开始执行任务！ 运动员-2 开始执行任务！ 运动员-4 开始执行任务！
可以看到，只有当四个线程都调用 await() 后，屏障才被解除，并先执行预设的 Runnable 任务，然后各线程继续向下运行。
实际应用场景
CyclicBarrier 在以下几种场景中尤为适用：
- 并行计算拆分任务：将一个大任务拆成多个子任务由不同线程处理，所有子任务完成后统一汇总结果。例如矩阵运算、大数据分片处理。
- 游戏或模拟系统中的同步启动：多个AI角色或玩家线程需要在同一时刻开始行动。
- 性能测试中的并发控制：确保多个测试线程同时发起请求，以准确测量系统在高并发下的表现。
- 周期性协同任务：由于 CyclicBarrier 支持重复使用，适合用于周期性的同步操作，比如每轮训练模型前等待所有工作节点准备好。
注意事项与常见问题
使用 CyclicBarrier 时需要注意以下几点：
- 如果某个线程在等待过程中被中断或抛出异常，会导致整个屏障进入断裂状态（broken），其他线程会收到 BrokenBarrierException。可以通过
isBroken()方法检测是否已损坏。 - 避免死锁：确保参与的线程数量和
parties数量一致，否则永远无法满足触发条件。 - 合理设置超时：可以使用
await(long timeout, TimeUnit unit)防止无限等待。 - 与 CountDownLatch 的区别：CountDownLatch 是一次性使用的，而 CyclicBarrier 可重复；前者是“等待事件发生”，后者是“等待线程集合到达”。
基本上就这些。CyclicBarrier 提供了一种简洁高效的线程协作方式，尤其适合需要“齐头并进”的同步场景。掌握它的使用，能让多线程程序更可控、更协调。
