cyclicbarrier 的执行顺序是“集体就位,统一出发”,所有线程在栅栏点同步抵达并同时放行;其计数器由最后一个到达线程归零并触发 barrieraction 后唤醒全部线程;支持多轮重用,适用于分阶段并行处理。

CyclicBarrier 的执行顺序本质是“集体就位,统一出发”。它不控制单个线程内部的步骤,而是强制所有参与线程在指定同步点(即栅栏)处暂停,直到全部到达,才同时放行——就像体育比赛的起跑线,发令枪响前所有人必须站定,缺一不可。
栅栏触发依赖“最后一个到达者”
每个线程调用 await() 时并不会立刻通过,而是进入等待状态。CyclicBarrier 内部维护一个计数器,每调用一次 await() 就减 1。当计数器归零(即最后一个线程抵达),该线程会负责两件事:
- 先执行可选的 barrierAction(如日志记录、结果合并等)
- 再唤醒所有等待线程,让它们一起继续向下执行
这意味着:执行顺序上,“最后那个线程”承担了协调职责,但所有线程在逻辑上是并行推进、同步抵达、同步出发的。
多轮同步靠自动重置机制
CyclicBarrier 的“Cyclic”体现在每次放行后,计数器会自动重置为初始值(parties),无需手动重建对象。因此同一实例可被反复使用:
- 第一轮:3 个线程分别执行 taskA → await() → 全部阻塞 → 最后一个触发 barrierAction → 同时进入 taskB
- 第二轮:3 个线程继续执行 taskB → await() → 再次集体等待 → 再次统一放行 → 进入 taskC
这种模式天然适合分阶段并行处理,比如图像分块渲染、矩阵分块计算、多路数据采集后的汇总等场景。
执行顺序不是线性排队,而是分组同步
和 CountDownLatch 不同,CyclicBarrier 不区分“主线程”和“工作线程”,所有参与者地位平等。它不保证线程启动先后顺序,也不干预各线程内部执行快慢——只约束它们在每个栅栏点的就位节奏:
- 线程 A 可能最早完成前半段任务,但它必须在第一个 await() 处停下等待 B 和 C
- 线程 C 即使最慢,只要它最终到达,就触发全体放行;若超时未到,则抛出 TimeoutException
- 任意线程在 await() 中被中断,或栅栏已被破坏(broken),其他等待线程会收到 BrokenBarrierException
实际编码中要注意的关键点
确保执行顺序可控,需关注几个细节:
- parties 数量要与实际启动线程数严格一致,少启一个,其余全卡死;多启一个,可能因计数溢出导致异常
- barrierAction 中避免耗时操作或阻塞调用,否则会拖慢全体线程的后续执行
- 使用带超时的 await(long, TimeUnit) 更健壮,防止某个线程长期失联导致整个组永久挂起
- 可通过 isBroken() 或 reset() 主动干预异常状态,但 reset() 会中断所有等待线程,需谨慎使用











