CyclicBarrier是Java并发包中支持重复使用的线程同步工具，用于让一组线程互相等待至全部到达屏障点后共同继续执行，并可选执行由最后到达线程触发的回调任务。
CyclicBarrier 是 Java 并发包（java.util.concurrent）中用于线程协作的同步工具，核心作用是让一组线程互相等待，直到全部到达某个“屏障点”，再一起继续执行。它比 CountDownLatch 更灵活，支持重复使用（即“循环”），也允许在所有线程就绪时触发一个可选的回调任务。
一、CyclicBarrier 的基本用法
创建时指定参与线程总数，并可选传入一个 Runnable 作为“屏障动作”——当最后一个线程调用 await() 到达屏障时，该动作会由**那个线程**执行，之后所有线程才同时被唤醒继续往下走。
每个线程在关键位置调用 await()，该方法会阻塞，直到满足以下任一条件：
- 已有指定数量的线程调用了
await()（即凑齐全部）； - 其他线程中断了当前线程；
- 等待超时（如果用了带超时的
await(long, TimeUnit)）； - 屏障被
reset()或损坏（如某线程 await 时抛出异常未处理）。
二、一个典型示例：多线程分段计算后统一汇总
假设有 4 个线程各自计算一部分数据，必须等全部算完，再一起输出总和：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.*;
<p>public class CyclicBarrierDemo {
private static final int THREAD_COUNT = 4;
private static int[] results = new int[THREAD_COUNT];
private static CyclicBarrier barrier = new CyclicBarrier(THREAD_COUNT, () -> {
// 所有线程到齐后执行：汇总结果
int sum = 0;
for (int r : results) sum += r;
System.out.println("✅ 全部完成，总和：" + sum);
});</p><pre class='brush:php;toolbar:false;'>public static void main(String[] args) {
for (int i = 0; i < THREAD_COUNT; i++) {
final int id = i;
new Thread(() -> {
// 模拟各自计算
int localResult = id * 10 + 5;
results[id] = localResult;
System.out.println("? 线程 " + id + " 算出：" + localResult);
try {
barrier.await(); // 到达屏障点，等待其他人
} catch (InterruptedException | BrokenBarrierException e) {
Thread.currentThread().interrupt();
}
}).start();
}
}}
运行时你会看到 4 行“? 线程 X 算出…”乱序打印，但“✅ 全部完成…”一定在最后且只出现一次——说明屏障成功同步了所有线程。
三、注意关键细节
-
异常要处理：
await()抛出BrokenBarrierException（屏障被破坏）、InterruptedException，不捕获会导致线程静默退出，其余线程永久阻塞； -
屏障可重用：只要没被
reset()或损坏，同一CyclicBarrier实例能多次使用（比如做多轮并行任务）； - 谁执行 barrier action？ 是**最后一个到达的线程**，不是专门的调度线程，所以不要在里面放耗时或阻塞操作，否则会拖慢整体进度；
- 与 CountDownLatch 的区别：后者是一次性、由主线程 await，适合“等待多个异步任务结束”；CyclicBarrier 是多方相互等待，适合“多线程协同分阶段执行”。
四、实用技巧：配合线程池与超时控制
实际项目中常结合 ExecutorService 使用，并加上超时避免死锁：
- 用
barrier.await(10, TimeUnit.SECONDS)防止某个线程挂掉导致全体卡住； - 捕获
TimeoutException后可调用barrier.reset()清理状态（注意 reset 会让已 await 的线程收到BrokenBarrierException）； - 若需知道当前是第几轮，可通过
getNumberWaiting()或自定义计数器辅助调试。
