Phaser阶段推进依赖线程显式调用arrive类方法触发,非自动递增;必须注册才能调用,动态注册推荐启动后立即register();阶段性退出须用arriveAndDeregister()原子完成;onAdvance可控制流转或终止。

Phaser 的分阶段执行不是靠“统一等齐再走”,而是靠每个线程显式到达 + 动态计数来驱动阶段推进。灵活等待的关键,在于让不同线程按需参与、适时退出、精准阻塞,而不是强行绑定所有线程到全部阶段。
阶段推进必须由到达动作触发
Phaser 的 phase 不会自动递增。只有当已注册的线程调用 arrive()、arriveAndAwaitAdvance() 或 arriveAndDeregister() 时,内部计数才响应。没调用到达方法,哪怕线程已就绪,phase 也卡住不动。
- 调用 arriveAndAwaitAdvance() 表示“我到了,且要等别人”——返回时 phase 已+1
- 只调 arrive() 是“我到了,但不等”,后续若需等待,得配 awaitAdvance(int),且该方法必须在 arrive 后调用,否则永远阻塞
- 主线程若只协调节奏(如启动子任务、收集结果),可不注册,改用 awaitAdvance(int) 监听阶段变化,避免卷入同步逻辑
动态注册要在线程启动后第一时间完成
new Phaser() 创建的是空同步器,构造参数不等于实际参与者。线程必须显式注册,否则 arrive* 方法会抛 IllegalStateException。
- 推荐初始化为 new Phaser(),各工作线程启动后第一句就是 phaser.register()
- 若所有线程能统一启动,可用 new Phaser(n) 简化,n 表示初始注册数(主线程含在内)
- 预分配大量 Worker 时,用 bulkRegister(n) 比循环 register() 更高效,但它仍是运行时操作,不是声明上限
阶段性退出必须原子执行
线程完成某阶段后不再参与后续流程,不能先 arrive() 再 deregister()——后者根本不是 public 方法。唯一正确方式是 arriveAndDeregister(),一次性完成“到达 + 注销”。
- 预处理线程做完阶段 0,立刻 arriveAndDeregister(),干净退出,不影响阶段 1 推进
- 校验线程在阶段 1 结束后同样注销;汇总线程则全程用 arriveAndAwaitAdvance(),直到最后再注销
- 错误写法:arriveAndAwaitAdvance() 后再调 arriveAndDeregister()——前者已推进 phase,后者可能落在新 phase,导致计数错乱
用 onAdvance 控制阶段流转与终止
onAdvance(int phase, int registeredParties) 是阶段切换前的钩子,适合做状态检查、清理或主动终止。
- 返回 false(默认)表示继续下一阶段
- 返回 true 表示终止 Phaser,后续 awaitAdvance() 立即返回负值
- 常见用法:if (phase == 2 && registeredParties == 0) return true; ——第三阶段结束且无人剩余,自然收尾
- 异常中断不会触发 onAdvance,若线程崩溃未注销,需配合 forceTermination() 主动熔断

















