phaser 的阶段同步由线程主动抵达驱动,phase 自动单调递增,无需手动重置;支持动态注册/注销参与者,主线程可深度协调;onadvance 可自定义阶段切换逻辑。

Phaser 的阶段同步不是靠“等齐再放行”的简单计数,而是由每个线程主动抵达(arrive)驱动的、带编号的协作节奏。它把“谁参与”和“推进到哪”彻底分开,让多线程任务能按业务阶段自然伸缩,不卡死、不残留、不误判。
阶段编号自动演进,无需手动重置
Phaser 内部维护一个从 0 开始单调递增的 phase 值。每次所有当前已注册且未注销的线程都调用过 arriveAndAwaitAdvance()(或等效到达操作)后,phase 自动 +1,进入下一阶段。这个过程完全由到达行为触发,不依赖定时器、不需 reset,也不受线程启停顺序干扰。
- 第一次调用
arriveAndAwaitAdvance()后,phase 变为 1 - 线程可通过
getPhase()实时读取当前阶段号,用于日志打点、异常回滚判断或条件分支 - 不要缓存 phase 值做后续逻辑——它可能在你读完瞬间就跳变了
动态参与者管理是阶段弹性的基础
固定人数的屏障(如 CyclicBarrier)无法应对线程中途退出、分片数变化或资源回收等真实场景。Phaser 允许运行时精确控制谁参与哪一阶段:
- 新线程启动后第一件事:调
phaser.register(),即刻成为当前阶段的合法参与者 - 某线程完成阶段性任务(如只负责预处理)、不再参与后续流程,必须调
arriveAndDeregister()—— 这是一个原子操作,既标记到达,又解除绑定 - 批量新增可用
bulkRegister(n),适合启动时预分配子任务池 - 注册与注销全程线程安全,多个线程并发调用不会破坏状态
主线程可作为协调者深度参与
Phaser 不区分“工作线程”和“控制线程”。主线程完全可以注册自己,再启动子线程并让它们注册,形成主从式编排:
- 初始化:
Phaser phaser = new Phaser(1),主线程先占位 - 子线程启动后立即
register(),注册成功才开始执行,确保计数准确 - 主线程可在关键节点调
awaitAdvance(phaser.getPhase()),等待所有子线程完成当前阶段后再下发下一步指令 - 若某子任务抛出未捕获异常,主线程可调
forceTermination(),其余等待线程将快速收到IllegalStateException并退出
阶段切换时插入自定义逻辑
重写 onAdvance(int phase, int registeredParties) 方法,就能在每次 phase 推进前执行检查或清理:
-
phase是刚刚结束的阶段号(例如 phase = 2 表示第 2 阶段已完成) -
registeredParties是下一阶段预计参与的线程数 - 返回
true表示终止 Phaser,后续arrive调用将返回负值;返回false继续下一阶段 - 常见用途:记录各阶段耗时、校验中间结果一致性、触发资源清理、或根据业务条件提前终止整个流程
不复杂但容易忽略











