cyclicbarrier 是 java 并发包中支持多线程协同到达屏障点后统一执行且可重复使用的同步工具，适用于分阶段并发计算场景；其通过计数器控制线程等待、触发屏障动作并自动重置，区别于一次性使用的 countdownlatch。
CyclicBarrier 是 Java 并发包（java.util.concurrent）中用于**多线程协同到达某个屏障点后统一继续执行**的工具，特别适合“分阶段并发计算”场景：多个线程各自独立完成某阶段任务，全部完成后，再一起进入下一阶段——可重复使用（即“循环”），这也是它和 CountDownLatch 的关键区别。
核心机制：等待 + 触发 + 复用
CyclicBarrier 内部维护一个计数器（初始为线程总数），每个线程调用 await() 时计数减一；当计数归零，所有等待线程被唤醒，触发可选的 屏障动作（barrier action）（如汇总、校验、初始化下一阶段数据）；之后计数器自动重置，可再次使用。
注意：await() 是阻塞调用，超时或中断会抛异常，需合理处理。
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
典型分阶段计算结构
以“三阶段并行处理”为例（如数据预处理 → 模型计算 → 结果聚合）：
- 创建
CyclicBarrier，指定参与线程数 + 可选的Runnable屏障动作 - 每个线程在每阶段末尾调用
await()，确保所有线程完成当前阶段才进入下一阶段 - 屏障动作中可安全访问各线程已写入共享变量的结果（因此时全部线程已完成本阶段）
- 重复上述过程，无需重建 barrier（“Cyclic”体现于此）
代码示例：两阶段并行求和
（简化版，突出逻辑）// 假设 4 个线程分段计算数组和
int[] data = {1,2,3,4,5,6,7,8};
int nThreads = 4;
CyclicBarrier barrier = new CyclicBarrier(nThreads, () -> {
// 所有线程完成阶段1后执行：汇总部分和到总和
System.out.println("✅ 阶段1完成，开始阶段2");
});
// 启动线程
for (int i = 0; i {
// 阶段1：各自计算子数组和，存入共享变量（如 AtomicIntegerArray）
int localSum = computeLocalPart();
// 阶段1结束，等待其他线程
try {
barrier.await(); // ⚠️ 可能抛 BrokenBarrierException / InterruptedException
} catch (Exception e) { return; }
// 阶段2：基于阶段1结果做后续计算（如归一化、比较）
doStage2BasedOnAllLocalSums();
}).start();
}
关键注意事项
-
线程安全共享数据：各阶段间传递结果需用线程安全容器（
AtomicIntegerArray、ConcurrentHashMap）或加锁，避免竞态 -
异常处理：任一线程 await 时中断或超时，屏障会被打破（
BrokenBarrierException），其他等待线程也会收到该异常，需统一恢复策略（如重置 barrier） - 与 CountDownLatch 区别：后者是一次性、主控线程等待子任务；CyclicBarrier 是参与者互相等待，且可循环，更适合对等协作的多阶段场景
- 性能提示：屏障点本身开销小，但大量线程频繁 await 可能引发调度竞争，若阶段粒度太细，反而降低并发收益
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
