说说 CyclicBarrier 原理
CyclicBarrier 是一个同步辅助类,允许一组线程互相等待,直到到达某个公共屏障点(CommonBarrierPoint)。因为该 barrier 在释放等待线程后可以重用,所以称它为循环的 barrier。
定义一句话讲完，原理要回答三个问题：到齐之前线程停在哪（等待机制）、到齐那一刻发生了什么（放行与 barrierAction）、为什么能循环（generation 代际）。本文按这三问展开，并补上破损语义与实战场景。
等待机制：ReentrantLock + Condition
与 CountDownLatch 基于 AQS 共享模式不同，CyclicBarrier 内部用一把 ReentrantLock 加一个 Condition（trip） 实现：
- 每个线程调用
await()时先持锁，把计数器count减一 - count 不为 0：当前线程在 trip 条件上
await()释放锁并挂起，等待被唤醒 - count 减到 0：**当前线程就是”最后一个到齐者”**，由它执行屏障动作并唤醒所有人
CyclicBarrier barrier = new CyclicBarrier(3); |
到齐时刻：dowait 的三步
最后一个到达的线程在 dowait() 中依次做：
- 执行 barrierAction（若构造时传入）：在锁保护下由最后到达者运行一次，适合做”本轮汇总”（如合并各线程的局部结果）
- 代际翻转（nextGeneration）：
generation++、count 重置回 parties、trip.signalAll()唤醒全部等待线程 - 等待者被唤醒后检查 generation 已变化，确认本轮屏障完成，各自返回继续执行
generation（代）是”循环”与”破损”两个语义的共同载体：正常翻代代表一轮完成；broken 翻代代表一轮作废。
循环重用与 reset
- 每轮放行后 count 自动重置，屏障对象可直接用于下一轮——无需新建，这是与 CountDownLatch 一次性语义的根本区别
reset()主动作废当前轮：正在等待的线程收到 BrokenBarrierException，generation 翻转、count 重置，屏障进入新一轮。适合”超时放弃本轮、重新开始”的策略
破损语义：一个人出问题，全体快速失败
任一参与者出现以下情况，屏障立即 broken：
- await 超时（带超时版本）
- 等待中被中断
- 屏障被 reset
- barrierAction 执行抛异常
broken 后所有等待者与后续到达者都抛 BrokenBarrierException——快速失败避免其余线程无意义陪等。恢复方式是 reset 或新建屏障。对比 CountDownLatch 的”计数泄漏即永久死等”，CyclicBarrier 的失败传播设计更健壮。
典型场景
- 多轮并行计算同步：矩阵分块迭代、MapReduce 式”局部计算-全局合并-再迭代”，每轮边界用 barrier 对齐
- 分阶段压测/对账：N 个线程各自准备数据，barrier 对齐后同时发压（比 sleep 等待精确）
- 多源数据凑齐再处理：如三家报价查询齐了再比价（barrierAction 里做汇总）
与 CountDownLatch / Semaphore 的定位
- CountDownLatch：等”事件完成”，一次性，等待方与计数方可不等量
- CyclicBarrier：等”参与者到齐”，可循环，参与者即等待者
- Semaphore：限”并发许可数”，不要求到齐，控制同时进行的数量
CyclicBarrier 的原理核心就两个对象：一把锁保护计数，一个条件队列停放等待者；而 generation 代际机制同时撑起了”循环”与”破损”两种生命周期语义。抓住这三点，API 行为皆可推导。
本博客所有文章除特别声明外，均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来源 非鱼小站！
相关推荐
2022-05-16
讲讲线程池的实现原理
当提交一个新任务到线程池时，线程池的处理流程如下： 线程池判断核心线程池里的线程是否都在执行任务。如果不是，则创建一个新的工作线程来执行任务。如果核心线程池里的线程都在执行任务，则进入下个流程。 线程池判断工作队列是否已经满。如果工作队列没有满，则将新提交的任务存储在这个工作队列里。如果工作队列满了，则进入下个流程。 线程池判断线程池的线程是否都处于工作状态。如果没有，则创建一个新的工作线程来执行任务。 三步流程是 ThreadPoolExecutor.execute 的行为描述，但实现层面真正精妙的是：一个 int 变量（ctl）同时编码了线程池状态与线程数，以及”Worker 线程自取任务”的运行模型。本文把流程落到源码机制，并讲清拒绝策略与生命周期。 ctl：一个原子整数的双重编码ThreadPoolExecutor 用 AtomicInteger ctl 的高 3 位表示池状态（RUNNING / SHUTDOWN / STOP / TIDYING / TERMINATED），低 29 位表示线程数。一次 CAS 即可原子地同时...
2022-05-18
线程的生命周期
New：新建 Runnable：就绪 Running：运行 Blocked：阻塞 Dead：死亡 五状态模型是操作系统教材的视角；Java 层面真正用于排障的是 Thread.State 枚举的六状态。两套模型的映射关系、以及每个阻塞状态对应的排查手段，才是这个知识点的实战价值。 Java 的六状态与五状态映射 Thread.State 含义 对应五状态 NEW 已 new 未 start New RUNNABLE 可运行/运行中（含等 CPU 与等 IO 的”假运行”） Runnable + Running BLOCKED 等监视器锁（synchronized 竞争失败） Blocked WAITING 无限期等待他线程动作（wait/join/park） Blocked TIMED_WAITING 带超时的等待（sleep(t)/wait(t)/parkNanos） Blocked TERMINATED 执行结束或异常退出 Dead 关键差异：Java 把”就绪”与”运行”合并为 RUNN...
2022-05-13
说说 Semaphore 原理
Semaphore 直译为信号。实际上 Semaphore 可以看做是一个信号的集合。不同的线程能够从 Semaphore 中获取若干个信号量。当 Semaphore 对象持有的信号量不足时，尝试从 Semaphore 中获取信号的线程将会阻塞。直到其他线程将信号量释放以后，阻塞的线程会被唤醒，重新尝试获取信号量。 信号量模型（P/V 操作）由 Dijkstra 提出，是操作系统课的经典内容；Java 的 Semaphore 把它落成了 AQS 共享模式的一个应用。本文讲清三件事：AQS 层如何实现许可计数、公平与非公平的差异、以及它在限流场景的正确用法与常见误用。 模型：许可（permits）池Semaphore 维护一组许可： acquire()：取一个许可，无许可则阻塞（P 操作） release()：还一个许可，可能唤醒等待者（V 操作） 构造参数 permits 决定同时允许多少个线程通过：permits=1 时退化为互斥锁；permits=N 时允许 N 个并发 Semaphore sem = new Semaphore(3); ...
2022-05-09
sleep、join、yield 有什么区别
sleep()sleep() 方法需要指定等待的时间，它可以让当前正在执行的线程在指定的时间内暂停执行，进入阻塞状态，该方法既可以让其他同优先级或者高优先级的线程得到执行机会，也可以让低优先级的线程得到执行机会。但是 sleep() 方法不会释放”锁标志”，也就是说如果有 synchronized 同步块，其他线程仍然不能访问共享数据。 wait()wait() 方法需要和 notify() 及 notifyAll() 两个方法一起介绍，这三个方法用于协调多个线程对共享数据的存取，所以必须在 synchronized 语句块内使用，也就是说，调用 wait()，notify() 和 notifyAll() 的任务在调用这些方法前必须拥有对象的锁。注意，它们都是 Object 类的方法，而不是 Thread 类的方法。 wait() 方法与 sleep() 方法的不同之处在于，wait() 方法会释放对象的”锁标志”。当调用某一对象的 wait() 方法后，会使当前线程暂停执行，并将当前线程放入对象等待池中，直到调用了 notify() 方法后，将从对象等待池中移出任意一个线程并放...
2022-05-08
创建线程的方式及实现
继承 Thread 类创建线程类 定义 Thread 类的子类，并重写该类的 run 方法，该 run 方法的方法体就代表了线程要完成的任务。因此把 run() 方法称为执行体。 创建 Thread 子类的实例，即创建了线程对象。 调用线程对象的 start() 方法来启动该线程。 通过 Runnable 接口创建线程类 定义 Runnable 接口的实现类，并重写该接口的 run() 方法，该 run() 方法的方法体同样是该线程的线程执行体。 创建 Runnable 实现类的实例，并依此实例作为 Thread 的 target 来创建 Thread 对象，该 Thread 对象才是真正的线程对象。 调用线程对象的 start() 方法来启动该线程。 通过 Callable 和 Future 创建线程 创建 Callable 接口的实现类，并实现 call() 方法，该 call() 方法将作为线程执行体，并且有返回值。 创建 Callable 实现类的实例，使用 FutureTask 类来包装 Callable 对象，该 FutureTask 对象封装了该 Callabl...
2022-05-10
说说 CountDownLatch 原理
CountDownLatch 解决的是一个非常具体的并发协调问题：一个（或多个）线程需要等待另外 N 个线程全部完成后，才能继续执行。典型如首页聚合接口：并行调用用户服务、订单服务、推荐服务，三个都返回后才能组装响应。本文从用法到 AQS 源码层把原理讲透。 用法模型CountDownLatch latch = new CountDownLatch(3);for (String svc : List.of("user", "order", "recommend")) { pool.submit(() -> { try { call(svc); // 并行发起远程调用 } finally { latch.countDown(); // 完成一个，计数减一 } });}latch.await(); ...
评论
WalineDisqus
