Phaser是Java 7引入的可重用、动态注册参与者的分阶段同步工具，适用于阶段明确、参与者数量可变且需多次执行多阶段流程的场景；CountDownLatch不可重置，CyclicBarrier固定人数且不支持分阶段，而Phaser通过arriveAndAwaitAdvance()自然表达阶段协同。
Phaser是什么，什么时候该用它而不是CountDownLatch或CyclicBarrier
Phaser是Java 7引入的可重用、动态注册参与者的同步工具，适合**阶段明确、参与者数量可能变化、需多次重复执行多阶段流程**的场景。比如：数据清洗→特征提取→模型训练→结果评估，每个阶段都依赖前一阶段完成，且不同任务可能在不同阶段加入或退出。
CountDownLatch不可重置，CyclicBarrier固定参与者数且不支持分阶段；Phaser用arriveAndAwaitAdvance()自然表达“我完成了本阶段，等所有人到齐再进下一阶段”，更贴近真实业务流。
如何正确初始化Phaser并动态注册参与者
别直接new Phaser()就开跑——漏注册会导致arriveAndAwaitAdvance()提前推进阶段，引发竞态。必须显式注册，尤其当线程是后续启动时。
- 主线程参与：用
new Phaser(1)，构造时声明自身为1个参与者 - 子线程参与：在启动前调用
phaser.register()（不是构造后立刻register，而是在线程run方法开头） - 避免在lambda中隐式注册：用
ExecutorService.submit(() -> { phaser.register(); ... })而非phaser.register(); executor.submit(...)，否则注册发生在主线程
Phaser phaser = new Phaser(1); // 主线程已注册
for (int i = 0; i < 3; i++) {
executor.submit(() -> {
phaser.register(); // 每个worker线程自己注册
// 阶段1：加载数据
System.out.println("Stage 1 start: " + Thread.currentThread().getName());
phaser.arriveAndAwaitAdvance();
// 阶段2：处理数据
System.out.println("Stage 2 start: " + Thread.currentThread().getName());
phaser.arriveAndAwaitAdvance();
});
}
phaser.arriveAndAwaitAdvance(); // 主线程也完成阶段1、2
怎么用onAdvance()控制阶段逻辑和终止条件
onAdvance(int phase, int registeredParties)在每次阶段推进前被调用，返回true表示Phaser终止（后续arriveAndAwaitAdvance()会立即返回，不再阻塞）。这是实现“自动结束”或“条件跳过阶段”的关键钩子。
立即学习“Java免费学习笔记（深入）”；
- phase从0开始，每调用一次
arriveAndAwaitAdvance()成功就+1 - registeredParties是当前还活着的参与者数（已
arriveAndDeregister()的不计） - 想执行3个阶段后停：在
onAdvance(2, ...)里return true - 想某阶段无人参与时跳过：检查
registeredParties == 0后return true，避免死等
Phaser phaser = new Phaser() {
protected boolean onAdvance(int phase, int registeredParties) {
if (phase == 2) {
System.out.println("All 3 stages done, phaser terminating.");
return true; // 终止
}
if (registeredParties == 0) {
System.out.println("No participants left, exiting.");
return true;
}
return false;
}
};
常见陷阱：deregister时机、getPhase()误用、线程中断响应
Phaser不像其他同步器那样对中断敏感——arriveAndAwaitAdvance()不会响应Thread.interrupt()，会一直阻塞。这容易掩盖设计缺陷。
-
arriveAndDeregister()必须成对出现：注册了就要注销，否则getRegisteredParties()虚高，阶段永远等不满 -
getPhase()返回的是**当前已推进到的阶段号**（即刚完成的阶段），不是“下一个将进入的阶段”。打印调试时别搞反 - 不要在循环里反复
new Phaser()模拟阶段——性能差且丢失状态；复用一个Phaser，靠onAdvance()控制流程 - 若需中断支持，得自己封装：用
phaser.awaitAdvanceInterruptibly(phase)，它会抛InterruptedException
最易忽略的是：Phaser的阶段推进是“所有已注册且未deregister的参与者都调用了arrive系方法后才触发”，一旦有线程忘记调用或异常退出没deregister，整个流程就卡死，且无超时机制——上线前务必做参与者生命周期审计。
