Phaser可替代CyclicBarrier，支持动态注册/注销线程、多阶段同步及重复使用，适用于参与线程数量不确定或需分阶段协调的场景，灵活性优于CyclicBarrier。
在Java中，Phaser 可以作为 CyclicBarrier 的替代方案，尤其适用于更灵活的同步场景。虽然 CyclicBarrier 适合固定数量线程的循环屏障，但 Phaser 提供了更动态的控制能力，比如支持动态注册/注销参与线程、可重用性更强、还能分阶段执行。
1. 理解两者核心区别
CyclicBarrier 要求所有参与线程在构造时就确定数量，一旦开始就不能更改。而 Phaser 允许线程动态加入或退出，并且可以多次重复使用，还支持分阶段（phase）的概念。
Phaser 的优势包括：
- 支持动态增减参与线程（通过 register() 和 arriveAndDeregister()）
- 每个阶段完成后自动进入下一阶段
- 可替代 CountDownLatch + CyclicBarrier 的组合功能
2. 使用 Phaser 模拟 CyclicBarrier 行为
假设我们有3个线程需要在每个阶段同步，等全部到达后再继续执行 —— 这正是 CyclicBarrier 的典型用法。下面用 Phaser 实现相同效果：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.Phaser;
public class PhaserAsBarrier {
public static void main(String[] args) {
// 创建 Phaser 并设置初始参与者数量为3
Phaser phaser = new Phaser(3);
for (int i = 0; i < 3; i++) {
new Thread(() -> {
System.out.println(Thread.currentThread().getName() + " 到达屏障");
// 等待其他线程到达
phaser.arriveAndAwaitAdvance();
System.out.println(Thread.currentThread().getName() + " 通过屏障");
}).start();
}
}
}
这里 arriveAndAwaitAdvance() 类似于 CyclicBarrier 的 await()：线程到达后等待其他人，全部到达后一起继续。
3. 动态添加和移除参与者
Phaser 的真正优势在于运行时调整参与线程数。例如，某些任务完成后主动退出同步流程：
Phaser phaser = new Phaser();
phaser.register(); // 主线程也参与
for (int i = 0; i < 3; i++) {
phaser.register(); // 动态注册工作线程
new Thread(() -> {
System.out.println("工作线程到达");
phaser.arriveAndAwaitAdvance();
System.out.println("工作线程继续执行");
phaser.arriveAndDeregister(); // 完成后注销自己
}).start();
}
// 主线程等待所有子线程完成第一阶段
phaser.arriveAndAwaitAdvance();
System.out.println("所有线程已通过第一阶段");
phaser.arriveAndDeregister(); // 主线程退出
这种方式比 CyclicBarrier 更灵活，特别是在任务数量不确定或生命周期不同的场景下。
4. 支持多阶段同步
Phaser 可用于多个连续阶段的协调。每次所有参与者调用 arrive 相关方法后，phase 值递增，可用于判断当前阶段：
Phaser phaser = new Phaser(3);
Runnable onAdvance = (phase, registeredParties) -> {
System.out.println("第 " + (phase + 1) + " 阶段完成，准备进入下一阶段");
return false; // 返回 true 会终止 phaser
};
new Thread(() -> {
phaser.arriveAndAwaitAdvance(); // 第一阶段同步
System.out.println("线程 A 完成第一阶段");
phaser.arriveAndAwaitAdvance(); // 第二阶段同步
System.out.println("线程 A 完成第二阶段");
}).start();
// 其他线程同理...
你还可以重写 onAdvance(int phase, int registeredParties) 方法来自定义每阶段结束时的行为。
基本上就这些。Phaser 在功能上完全能替代 CyclicBarrier，而且提供了更多控制自由度。如果你的应用需要动态参与、阶段性处理或多轮同步，Phaser 是更优选择。
