CyclicBarrier 的核心价值在于支持多轮线程同步协作,确保所有线程到齐后才共同推进,适用于分批处理、阶段计算等场景;它通过 await() 实现集体就位,可配置屏障动作、超时机制,并天然可重用。

CyclicBarrier 的核心价值在于让多个线程“齐步走”——不是谁先做完谁先走,而是所有人到齐才一起迈下一步,且这一步可以重复多次。它不像 CountDownLatch 用完即废,而是天然支持多轮协作,特别适合分批处理、阶段式计算、协同初始化等场景。
任务组同步:确保所有线程按周期集体就位
创建 CyclicBarrier 时指定参与线程数(parties),就是定义一个“任务组”的规模。每个线程完成自身工作后调用 await(),即宣告“我已就位”。此时该线程会被挂起,直到组内最后一个线程也调用 await(),屏障才被触发,所有等待线程同时恢复执行。
- 必须保证每个线程在每轮中**恰好调用一次 await()**;少调会导致部分线程永久阻塞,多调可能提前触发或引发 BrokenBarrierException
- 推荐配合线程池使用,例如 FixedThreadPool,避免手动管理线程生命周期带来的不确定性
- 可通过 getNumberWaiting() 实时查看当前还有几个线程没到,便于调试和监控
屏障动作:在全体就位瞬间执行关键协调逻辑
构造 CyclicBarrier 时传入的 Runnable 参数,会在所有线程到达后、释放前由最后一个到达的线程**串行执行**。这是做汇总、校验、状态更新或日志记录的理想位置。
将后端 Java 接口文档转换为前端 TypeScript 类型定义(interface / type)。输入:飞书文档、Spring Boot 接口文档、Swagger/OpenAPI、手写 API 文档等。输出:包含请求参数与响应结果的 .md 文件,含完整 JSDoc 注释。触发关键词:Java 转 TS、接口转换、生成前端类型、接口文档转 TypeScript、DTO/VO/BO 转 interface、后端文档转前端类型、生成接口类型、类型定义生成。
- 屏障动作应轻量,控制在毫秒级完成;若耗时过长,会成为整个任务组的性能瓶颈
- 常见用途包括:合并各线程的局部计算结果、刷新共享统计指标、检查是否需要终止后续轮次、写入中间快照等
- 动作中抛出未捕获异常会使屏障破损(isBroken() 返回 true),后续 await() 都会立即抛出 BrokenBarrierException
异常与超时:保障任务组健壮运行
await() 方法可能抛出 InterruptedException 或 BrokenBarrierException,实际编码中不可忽略:
- 遇到 InterruptedException,通常意味着线程被外部中断,需决定是退出当前轮次还是重试
- BrokenBarrierException 表明屏障已被破坏(如某线程超时或中断离开),此时屏障不可再用,需重建或统一协调恢复
- 强烈建议使用带超时的 await(long timeout, TimeUnit unit),防止某个子任务卡死拖垮整体进度
重用与重置:真正实现“循环”协作
CyclicBarrier 天然可重用——一轮结束后自动重置计数器,无需重新 new 实例。但若发生破损(broken),则无法自动恢复,必须显式重建。
- 正常流程下,每轮 await() 返回后,屏障即可用于下一轮,无需额外操作
- 若某轮因异常中断,可通过 isBroken() 判断状态,并在必要时新建 CyclicBarrier 实例继续流程
- 注意:reset() 方法虽存在,但仅适用于极少数需强制恢复破损屏障的场景,多数情况下重建更清晰安全










