Phaser支持动态注册线程并协调多阶段执行，通过arriveAndAwaitAdvance同步阶段，register添加参与者，onAdvance自定义阶段结束逻辑，实现灵活的多线程协作。
在Java中，Phaser 是一种灵活的同步工具，适用于需要分阶段执行的多线程协作场景。与 CountDownLatch 或 CyclicBarrier 不同，Phaser 支持动态注册线程，并能协调多个阶段的执行，每个阶段完成后自动进入下一阶段。
Phaser的基本工作原理
Phaser 允许线程在每个阶段到达时进行同步。当所有参与线程都调用 arriveAndAwaitAdvance() 后，Phaser 自动进入下一阶段。线程可以通过 register() 或构造时指定数量来加入Phaser。
关键方法包括：
- arriveAndAwaitAdvance()：线程到达当前阶段并等待其他线程完成
- arriveAndDeregister()：到达后退出Phaser，不再参与后续阶段
- register()：动态注册一个新参与者
- getPhase()：获取当前阶段编号（从0开始）
实现多阶段任务同步
假设我们有三个线程需要协同完成两个阶段的任务，可以这样使用 Phaser：
立即学习“Java免费学习笔记（深入）”；
Phaser phaser = new Phaser(3); // 初始化3个参与者
Runnable task = () -> {
// 第一阶段
System.out.println(Thread.currentThread().getName() + " 完成第一阶段");
phaser.arriveAndAwaitAdvance();
// 第二阶段
System.out.println(Thread.currentThread().getName() + " 完成第二阶段");
phaser.arriveAndAwaitAdvance();
};
// 启动三个线程
for (int i = 0; i < 3; i++) {
new Thread(task).start();
}
输出会显示所有线程先完成第一阶段，再一起进入第二阶段。
动态添加参与者和终止阶段
Phaser 支持运行时注册新线程，适合任务中途加入的场景：
Phaser phaser = new Phaser(1); // 主线程作为参与者
new Thread(() -> {
phaser.register(); // 动态加入
System.out.println("子线程执行阶段1");
phaser.arriveAndAwaitAdvance();
System.out.println("子线程执行阶段2");
phaser.arriveAndAwaitAdvance();
}).start();
// 主线程控制流程
System.out.println("主线程准备阶段");
phaser.arriveAndAwaitAdvance(); // 等待所有线程完成阶段1
System.out.println("进入阶段2");
phaser.arriveAndDeregister(); // 主线程退出
自定义阶段结束判断
通过重写 onAdvance() 方法，可以在每个阶段结束时执行自定义逻辑，甚至决定是否继续：
Phaser phaser = new Phaser(2) {
protected boolean onAdvance(int phase, int registeredParties) {
System.out.println("第 " + (phase + 1) + " 阶段结束");
return phase >= 1 || registeredParties == 0; // 执行两阶段后停止
}
};
该方法在每个阶段结束后被调用，返回 true 表示Phaser终止。
基本上就这些。Phaser 提供了比传统同步工具更精细的阶段控制能力，特别适合复杂工作流的协调。掌握它的注册机制、阶段推进和生命周期管理，就能高效组织多阶段并发任务。
