phaser 的阶段(phase)是自动递增的同步周期标识,初始为0,每次所有活跃参与者调用arriveandawaitadvance后加1;phase只读,反映当前协作轮次,支持多轮差异化逻辑与动态成员管理。

Phaser 的“阶段”(Phase)不是用户显式定义的步骤,而是由 Phaser 自动维护的一个整数计数器,每次所有已注册的参与者都到达当前阶段的栅栏点(arriveAndAwaitAdvance)后,阶段号自动加 1。它本质是同步周期的序号,用于刻画并行任务在多轮协作中的进度位置。
阶段号(phase)是自动推进的同步周期标识
Phaser 不需要你预先声明“第1阶段做什么、第2阶段做什么”。它的 phase 值从 0 开始,每当所有当前已注册且未注销的参与者都调用 arriveAndAwaitAdvance()(或等效同步方法),Phaser 就完成一轮等待、触发屏障、将 phase 增加 1,并唤醒所有线程进入下一周期。这个过程完全自动,无需手动递增或重置。
- 初始 phase 为 0;第一次全体到达后变为 1,第二次变为 2,依此类推
- 任意线程可通过 getPhase() 读取当前阶段号,用于条件判断(如“仅在偶数阶段做日志”)
- phase 是只读快照——不能直接设置,但可通过 forceUnarrived(int parties) 或注销/重新注册间接影响后续推进节奏
阶段与参与者的生命周期紧密绑定
Phaser 的阶段推进依赖于“活跃参与者数量”。只有当当前注册的所有线程(或任务)都到达该轮栅栏,阶段才会前进。如果某个参与者提前 deregister(注销)或异常终止未到达,其余线程将在该阶段永久阻塞(除非使用超时或取消机制)。
Java JDK 25 来自 OpenJDK 官方归档,版本为 JDK 25,本条下载地址已指向官方 Windows x64 zip 安装包直链,适合调试旧项目或兼容旧版 Java 运行环境。
- 新增参与者(如调用 register() 或 bulkRegister(n))不影响当前阶段推进,但会参与下一阶段的同步
- 调用 arriveAndDeregister() 既抵达当前阶段,又退出后续阶段,使所需到达数减 1
- 若某线程在 phase=5 时注销,则 phase=5 仍需剩余参与者全部到达才能升至 6
利用阶段号实现多轮协同逻辑
阶段号是区分不同同步轮次的关键依据,适合编写“每轮行为不同”的并行算法,比如迭代计算、分片重试、阶段性资源切换等。
- 可在 onAdvance(int phase, int registeredParties) 回调中定制阶段切换逻辑:返回 true 表示终止 Phaser;返回 false 继续下一轮
- 例如:每 3 轮执行一次汇总(
if (phase % 3 == 2) { doSummary(); }) - 也可结合 arriveAndDeregister() 实现“阶段性淘汰”——某些线程完成任务后退出,不再参与后续阶段
注意阶段语义与 Barrier/CyclicBarrier 的区别
不同于 CyclicBarrier 的“单阶段循环”,Phaser 的阶段是单调递增的整数序列,天然支持动态成员变化和多阶段异构行为。它不强调“固定轮数”,而强调“按需推进”,更适合生命周期不一致的协作场景。
- CyclicBarrier 每次 await() 都复用同一屏障;Phaser 每次 arriveAndAwaitAdvance() 都对应一个新 phase
- Phaser 支持树形结构(父子 Phaser),子 Phaser 的 phase 推进可独立于父级,实现嵌套阶段管理
- 阶段中断(interrupt)会导致当前线程抛出 InterruptedException,但不会阻止其他线程完成该阶段——phase 仍会正常推进
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南










