17370845950

Phaser可替代CyclicBarrier，支持动态注册/注销线程、多阶段同步及重复使用，适用于参与线程数量不确定或需分阶段协调的场景，灵活性优于CyclicBarrier。

在Java中，Phaser 可以作为 CyclicBarrier 的替代方案，尤其适用于更灵活的同步场景。虽然 CyclicBarrier 适合固定数量线程的循环屏障，但 Phaser 提供了更动态的控制能力，比如支持动态注册/注销参与线程、可重用性更强、还能分阶段执行。

1. 理解两者核心区别

CyclicBarrier 要求所有参与线程在构造时就确定数量，一旦开始就不能更改。而 Phaser 允许线程动态加入或退出，并且可以多次重复使用，还支持分阶段（phase）的概念。

Phaser 的优势包括：

• 支持动态增减参与线程（通过 register() 和 arriveAndDeregister()）
• 每个阶段完成后自动进入下一阶段
• 可替代 CountDownLatch + CyclicBarrier 的组合功能

2. 使用 Phaser 模拟 CyclicBarrier 行为

假设我们有3个线程需要在每个阶段同步，等全部到达后再继续执行 —— 这正是 CyclicBarrier 的典型用法。下面用 Phaser 实现相同效果：

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 是更优选择。