Phaser支持动态注册与多阶段同步，适用于线程数可变的分阶段协作场景。创建Phaser实例并指定初始参与者数量后，各线程在每个阶段调用arriveAndAwaitAdvance()阻塞等待，直至所有参与者到达后进入下一阶段。通过重写onAdvance()方法可定义阶段切换逻辑，返回true则终止同步。使用register()或bulkRegister(n)动态添加参与者，arriveAndDeregister()主动退出。示例中3个线程执行3个阶段（0、1、2），onAdvance在完成第2阶段后返回true结束。Phaser优势在于灵活应对运行时线程变化，适合流水线、并行算法等多轮迭代任务，关键在于掌握arriveAndAwaitAdvance与onAdvance配合及阶段从0开始的计数规则。
在Java中，Phaser 是一个灵活的同步工具，适用于需要分阶段执行的多线程协作场景。与 CountDownLatch 或 CyclicBarrier 不同，Phaser 支持动态注册和多阶段同步，非常适合处理多个阶段、线程数量可变的任务。
Phaser的基本原理
Phaser 允许线程在多个阶段（phase）上进行同步。每个阶段开始时，Phaser 会等待所有已注册的参与者（parties）到达，一旦全部到达，就进入下一阶段。你可以通过 arriveAndAwaitAdvance() 方法让线程在当前阶段同步阻塞。
Phaser 还支持动态添加或移除参与者，使用 register()、bulkRegister(n) 添加，使用 arriveAndDeregister() 主动退出。
实现多阶段同步的步骤
以下是如何使用 Phaser 实现多阶段线程同步的关键操作：
立即学习“Java免费学习笔记（深入）”；
- 创建 Phaser 实例，可指定初始参与线程数
- 每个工作线程在每个阶段调用 arriveAndAwaitAdvance() 等待其他线程
- 当所有线程完成当前阶段后，Phaser 自动进入下一阶段
- 可通过重写 onAdvance() 方法定义阶段切换时的逻辑，返回 true 可终止 Phaser
示例代码：
import java.util.concurrent.Phaser;
public class MultiStageSync {
public static void main(String[] args) {
Phaser phaser = new Phaser(3); // 初始3个参与者
for (int i = 0; i < 3; i++) {
new Thread(new Worker(phaser, "Thread-" + i)).start();
}
}
static class Worker implements Runnable {
private final Phaser phaser;
private final String name;
Worker(Phaser phaser, String name) {
this.phaser = phaser;
this.name = name;
}
@Override
public void run() {
for (int phase = 0; phase < 3; phase++) {
System.out.println(name + " 正在执行第 " + phase + " 阶段");
// 等待所有线程完成当前阶段
phaser.arriveAndAwaitAdvance();
// 模拟工作
try {
Thread.sleep(500);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
System.out.println(name + " 完成所有阶段");
}
}
}
控制阶段切换与终止
如果想在特定阶段后停止同步，可以重写 onAdvance() 方法。该方法在每次阶段切换前被调用，接收当前阶段号和参与者数量，返回 true 表示 Phaser 应终止。
例如：在第三阶段结束后停止
Phaser phaser = new Phaser(3) {
@Override
protected boolean onAdvance(int phase, int registeredParties) {
System.out.println("完成第 " + phase + " 阶段，参与者数：" + registeredParties);
return phase >= 2; // 执行完第2阶段后结束（共0,1,2三阶段）
}
};
基本上就这些。Phaser 的优势在于它既能处理固定阶段任务，也能应对运行时动态加入线程的场景，适合构建流水线、并行算法或多轮迭代任务。掌握 arriveAndAwaitAdvance 和 onAdvance 的配合使用，就能有效管理复杂的阶段性同步逻辑。不复杂但容易忽略的是线程注册时机和阶段计数从0开始。
