phaser 的 phase 管理由内部状态自动驱动,无需手动维护阶段变量;每次所有注册参与者到达后 phase 隐式+1,支持动态注册/注销与阶段对齐,通过 register/arriveandderegister 配合及 awaitadvance 时机控制实现高效协同。

Phaser 的 phase 管理不是靠手动维护阶段变量,而是由内部状态自动驱动:每次所有当前注册的参与者都到达后,phase 值隐式 +1;任务可随时加入或退出,不影响其他线程节奏。关键在于 register / arriveAndDeregister 的配合,以及对 awaitAdvance 时机的准确把握。
动态注册与阶段对齐
新任务启动时必须先调用 register(),否则后续任何 arrive 操作都会抛 IllegalStateException。注册后若希望立即参与当前阶段(而非从下一 phase 开始),需紧接着调用 arriveAndAwaitAdvance() —— 这一步完成“对齐”,确保它和已有线程同步推进。
- 避免在未 register 前调用 arrive()、arriveAndAwaitAdvance() 或 arriveAndDeregister()
- 批量拉起子任务时,优先用 bulkRegister(n) 替代循环 register(),减少开销
- 初始创建 Phaser 应使用 new Phaser() 或 new Phaser(null, 0),不预设人数
任务中途取消与阶段退出
当某个线程只参与部分阶段(如仅负责数据分发,不参与结果聚合),应在完成该阶段后调用 arriveAndDeregister()。它会原子性地完成三件事:标记本阶段到达、注销自身、触发 phase 推进(如果满足条件)。
- 注销后该线程对后续所有 phase 完全隐身,不会影响计数或等待逻辑
- 若任务需跨多个阶段但中间某次不参与,可用 arrive()(不阻塞)+ 后续再 register 回归,但需自行管理状态
- 大量微任务频繁注册/注销可能引发内部数组扩容,此时应评估是否改用 CompletableFuture 链式编排
主线程协调与阶段等待
主线程不必作为参与者注册,只需用 awaitAdvance(int phase) 等待特定阶段结束。例如:启动所有 worker 后,调用 phaser.awaitAdvance(0) 等待 phase 0(初始化)全部完成,再触发 phase 1(计算)逻辑。
- phaser.getPhase() 返回当前已推进到的 phase 编号(即已完成的阶段数)
- phaser.getRegisteredParties() 和 phaser.getUnarrivedParties() 是调试关键指标
- 若需在每阶段结束时执行统一操作(如日志、清理),重写 onAdvance(int phase, int registeredParties)
嵌套结构支持分组协同
对于天然分组的任务(如 Map-Reduce),可用父子 Phaser 构建树形结构:子组创建时传入父 Phaser 实例(new Phaser(parent))。子组完成自己的 phase 时,会自动为父 Phaser 调用一次 arrive()。
- 父 Phaser 的 phase 推进,代表“所有子组均已抵达当前阶段”
- 这种层级设计降低高并发下的竞争,也使流程更贴近业务语义
- 注意:子 Phaser 注册到父级后,其生命周期独立,但阶段推进与父级联动











