CyclicBarrier 同步机制是带状态管理、线程协作与异常防护的闭环流程:线程通过 await() 获取锁、检查破损、减计数并阻塞;最后一个线程触发 barrierCommand、唤醒所有线程、重置计数并创建新 Generation;唤醒线程需重获锁、验状后返回 index;破损后需 reset() 强制开启新轮次。

CyclicBarrier 的同步流程不是简单“等齐再走”,而是一套带状态管理、线程协作与异常防护的闭环机制。理解它,关键在于看清线程如何被组织、计数如何流转、屏障如何“呼吸”——即到达、触发、重置、再出发。
屏障等待:线程进入阻塞队列的精确过程
每个调用 await() 的线程都会先获取内部 ReentrantLock,确保操作原子性。接着执行三步核心动作:
- 检查当前 Generation 是否已破损(broken = true),若破损则直接抛出 BrokenBarrierException
- 将共享变量 count 减 1,得到当前线程在本轮等待中的序号(index)
- 若 count != 0,该线程进入 Condition trip 的等待队列并释放锁,进入阻塞状态
屏障触发:最后一个线程承担“哨兵”角色
当某线程使 count 减至 0,它就成为本轮的“最后一个到达者”,立即承担三项职责:
- 若构造时传入了 barrierCommand(Runnable),由它独占执行该回调任务——注意:不新开线程,就在当前线程上下文中运行
- 调用 nextGeneration():唤醒 trip 队列中所有等待线程,并重置 count = parties
- 创建新的 Generation 对象,标志本轮结束、下一轮就绪
线程释放与状态切换:从阻塞到继续执行
被唤醒的线程不会立刻恢复执行,而是重新竞争锁;获得锁后,它们会:
- 确认当前 Generation 未被破坏(避免唤醒后遭遇中断或重置异常)
- 从 dowait() 返回,返回值为自己的 index(0 表示最后到达,常用于主控逻辑判断)
- 继续执行 await() 后的代码,进入下一阶段任务
异常与重用边界:BrokenBarrierException 与 reset() 的真实含义
屏障一旦因中断、超时或显式调用 breakBarrier() 而破损,所有正在等待或后续调用 await() 的线程都会收到 BrokenBarrierException。此时屏障不可自动恢复。
- reset() 并非“重启”破损的屏障,而是主动将当前 Generation.broken = true,并新建一代——适用于你明确要放弃当前轮次、强制开启新轮次的场景
- 正常完成一轮后,count 自动重置、Generation 自动更新,这才是真正的“循环”基础
- 超时版 await(long, TimeUnit) 在超时时也会破坏屏障,需捕获 TimeoutException 并处理后续逻辑

















