CyclicBarrier是Java并发包中支持重复使用的线程同步工具，用于让一组线程互相等待至全部到达屏障点后才共同继续执行；它可指定到达时由最后线程执行回调任务，且需处理InterruptedException和BrokenBarrierException异常。
CyclicBarrier 是 Java 并发包（java.util.concurrent）中用于协调多个线程在某个“屏障点”同步等待的工具。它的核心作用就是：**让一组线程互相等待，直到全部到达指定的同步点，才一起继续执行。** 这和 CountDownLatch 的“单次倒计时、不可重用”不同，CyclicBarrier 支持重复使用（即“循环”），适合多轮协作场景（比如多线程分段计算、并行迭代等）。
怎么创建并使用 CyclicBarrier
创建时需指定参与等待的线程总数，并可选传入一个 Runnable 任务——当所有线程都到达屏障点时，由**最后一个到达的线程**负责执行该任务（常用于汇总、日志、清理等）：
CyclicBarrier barrier = new CyclicBarrier(3, () -> {
System.out.println("所有线程已就位，开始下一阶段");
});每个线程在到达同步点时调用 barrier.await()：
- 如果还没凑够指定数量，当前线程会阻塞等待；
- 一旦达到指定数量，所有等待线程被同时唤醒，继续向下执行；
- 屏障被“释放”，可再次使用（下一轮等待）。
关键细节和注意事项
await() 方法会抛出两个受检异常，必须处理：
立即学习“Java免费学习笔记（深入）”；
-
InterruptedException：线程在等待时被中断； -
BrokenBarrierException：屏障已被破坏（如某线程超时、中断、或 await 失败后未重置）。
常见破坏屏障的情况包括：
- 某个线程在
await()时被中断； - 某个线程调用
await()超时（使用带 timeout 的重载方法）且未等到其他线程； - 屏障初始化后未重置，但之前已因异常进入破损状态。
可通过 isBroken() 检查当前屏障是否处于破损状态，用 reset() 强制重置（慎用，可能影响正在等待的线程）。
一个典型使用示例
模拟 3 个线程各自准备数据，全部就绪后再统一提交：
CyclicBarrier barrier = new CyclicBarrier(3, () -> {
System.out.println("✅ 所有数据准备完毕，开始批量提交");
});
<p>for (int i = 0; i < 3; i++) {
new Thread(() -> {
System.out.println(Thread.currentThread().getName() + " 正在准备数据...");
try {
Thread.sleep(1000 + (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-1 正在准备数据... Thread-2 正在准备数据... Thread-1 数据准备完成 Thread-0 数据准备完成 Thread-2 数据准备完成 ✅ 所有数据准备完毕，开始批量提交 Thread-0 开始提交... Thread-1 开始提交... Thread-2 开始提交...
和 CountDownLatch 的主要区别
别混淆两者：
-
CountDownLatch：一个或多个线程等待**另一组线程完成某件事**（如初始化、启动信号），计数器只减不增，不可重用； -
CyclicBarrier：**一组线程彼此等待**，共同到达某点后一起出发，可重复使用，更强调“协同步进”。
简单记：Latch 是“等别人做完”，Barrier 是“大家一起到齐再走”。
