CyclicBarrier 是 Java 中用于多线程周期性同步的可重用工具类，支持到达-触发-重置流程、屏障动作执行及超时控制，适用于分片计算后周期性聚合等场景。
CyclicBarrier 是 Java 并发包（java.util.concurrent）中用于**多线程周期性同步**的工具类，特别适合“多个子任务并行执行 → 每轮结束后统一等待 → 全部到达后继续下一轮”的场景。它比 CountDownLatch 更灵活，因为可重复使用（“Cyclic”即循环之意），且支持在所有线程到达屏障时执行一个可选的“屏障动作”（Runnable）。
核心机制：理解 barrier 的“到达-触发-重置”流程
每个 CyclicBarrier 初始化时指定参与线程数（parties）。每当一个线程调用 await()，就视为“到达屏障”：
- 若未满员，该线程被阻塞，等待其他线程也调用
await()； - 当第
parties个线程调用await()，屏障被“触发”：所有等待线程同时被唤醒； - 若构造时传入了
Runnable，它会在最后到达的线程释放前、所有线程唤醒前执行（常用于汇总、日志、校验等）； - 屏障自动重置，可立即用于下一轮同步。
典型应用：多线程分片计算 + 周期性聚合
假设你有 100 万条数据，需按每批 1 万条分给 10 个线程并行处理（如数值变换、模型预测），每处理完一批（即一个“周期”），需汇总结果、更新状态、或检查是否中止。这时 CyclicBarrier 就是自然选择：
Java注释规范Skills
下载
当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式，或要求按照代码注释规范处理 Java 文件时，使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则，并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括：补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 Java 注释风格。
- 创建
CyclicBarrier(10, aggregationTask)，10 表示 10 个子任务线程； - 每个线程处理完自己那批数据后，调用
barrier.await()； - 第 10 个线程到达时，
aggregationTask执行（例如合并 10 个局部结果到全局容器）； - 所有线程从
await()返回，开始下一批处理（或退出）。
关键编码要点与避坑提醒
实际使用中需注意以下细节：
立即学习“Java免费学习笔记（深入）”；
-
异常处理必须覆盖：
await()可能抛出InterruptedException（线程被中断）或BrokenBarrierException（屏障被破坏，如某线程超时离开或被中断）。务必在catch中判断是否需重试、记录或终止整个流程； -
屏障动作（
Runnable）应在毫秒级完成：它由最后一个到达的线程串行执行，若耗时过长，会拖慢所有线程的下一轮启动； -
避免死锁：确保每个参与线程在每个周期内**恰好调用一次
await()**；漏调或重复调用都会导致部分线程永远阻塞或提前触发； -
超时控制很实用：使用
await(long timeout, TimeUnit unit)防止某个子任务因异常卡住，拖垮整体。超时后抛出TimeoutException，此时屏障进入破损状态，需重建或协调恢复。
一个最小可运行示例
以下代码模拟 3 个线程并行生成随机数，每轮后打印各自结果并汇总平均值：
CyclicBarrier barrier = new CyclicBarrier(3, () -> {
double avg = (sum1 + sum2 + sum3) / 3.0;
System.out.println("【汇聚】本轮平均值：" + avg);
});
// 启动 3 个线程，各自循环执行
for (int i = 0; i < 3; i++) {
new Thread(() -> {
for (int round = 0; round < 5; round++) {
int localSum = ThreadLocalRandom.current().nextInt(10, 100);
System.out.println("线程 " + Thread.currentThread().getId() + " 第" + round + "轮结果：" + localSum);
try {
barrier.await(); // 等待其他线程完成本轮
} catch (Exception e) {
e.printStackTrace();
return;
}
}
}).start();
}
