Java Phaser分阶段同步屏障替代CyclicBarrier的优势

Java并发包（J.U.C）中的 Phaser 是一个功能强大的同步工具，它解决了 CyclicBarrier 和 CountDownLatch 在某些复杂场景下的局限性。Phaser 提供了更灵活的线程同步机制，特别是在线程数量动态变化或多阶段任务协同的场景中，具有不可替代的优势。

1. 理解动态线程管理

CyclicBarrier 要求在构造时就指定固定的参与方数量，一旦设定，运行过程中无法修改。这在需要根据运行时条件动态增减工作线程的场景中显得非常笨拙。

使用 Phaser 可以完全解决这个问题。它允许线程在运行时随时注册或注销。

1. 创建 一个 Phaser 实例。如果不指定初始参与数，默认为 0。
2. 调用 register() 方法增加一个新的参与方。这通常在主线程或新启动的工作线程开始时执行。
3. 调用 bulkRegister(int parties) 方法一次性增加多个参与方。
4. 调用 arriveAndDeregister() 方法。当线程完成任务不再需要参与后续同步时，此方法会通知 Phaser 当前线程已到达并立即退出同步屏障，同时减少参与总数。

这种机制使得线程池中的线程可以按需加入任务同步，而不必预先锁死线程数量。

2. 实现多阶段并发任务

CyclicBarrier 的名字暗示了它是“循环”使用的，但每次重置（reset()）都需要手动触发，且如果有线程卡在屏障上，重置可能会导致线程抛出异常。Phaser 则天然支持“分阶段”的概念，阶段会自动推进，无需手动重置。

1. 编写 任务逻辑。在每个阶段的结束点，调用 arriveAndAwaitAdvance()。
2. 执行 该方法。线程会告诉 Phaser 当前阶段已完成，并等待其他所有线程也完成当前阶段。
3. 观察 阶段自动切换。当最后一个线程到达时，Phaser 会自动将“阶段号”加 1（从 0 开始），所有等待的线程会被唤醒并进入下一阶段。

这种自动推进机制非常适合迭代算法，例如：每个迭代步骤都需要所有线程对齐一次（交换数据或计算全局状态）。

以下是使用 Phaser 实现多阶段任务的代码示例：

import java.util.concurrent.Phaser;

public class PhaserDemo {
    public static void main(String[] args) {
        int parties = 3;
        Phaser phaser = new Phaser(parties);

        for (int i = 0; i < parties; i++) {
            new Thread(new Task(phaser), "Thread-" + i).start();
        }
    }

    static class Task implements Runnable {
        private final Phaser phaser;

        Task(Phaser phaser) {
            this.phaser = phaser;
        }

        @Override
        public void run() {
            // 阶段 1
            System.out.println(Thread.currentThread().getName() + " 执行阶段 1");
            phaser.arriveAndAwaitAdvance(); // 等待其他线程完成阶段 1

            // 阶段 2
            System.out.println(Thread.currentThread().getName() + " 执行阶段 2");
            phaser.arriveAndAwaitAdvance(); // 等待其他线程完成阶段 2

            // 阶段 3
            System.out.println(Thread.currentThread().getName() + " 执行阶段 3");
            phaser.arriveAndDeregister(); // 完成所有任务并注销
        }
    }
}

3. 监控与层次结构

Phaser 提供了比 CyclicBarrier 更丰富的状态监控方法，并且支持树形层次结构以减少竞争。

1. 获取 当前阶段号。调用 getPhase() 方法，返回当前的轮次（从 0 开始）。

2. 获取 注册的参与方数量。调用 getRegisteredParties() 方法。

3. 获取 已到达的参与方数量。调用 getArrivedParties() 方法。

4. 构建 层次结构。当参与方数量成千上万时，所有线程竞争同一个 Phaser 的原子变量会成为性能瓶颈。构造 子 Phaser 并将父 Phaser 作为参数传入。

   Phaser parent = new Phaser();
   Phaser child = new Phaser(parent);

   这使得子 Phaser 只需要与父 Phaser 同步，而不是与所有其他线程直接同步，从而降低了竞争强度。

4. 核心特性对比

下表总结了 Phaser 与 CyclicBarrier 的关键差异：

5. 自定义终止逻辑

Phaser 提供了一个 onAdvance(int phase, int registeredParties) 方法，你可以重写此方法来定义何时终止同步过程。

1. 重写 onAdvance 方法。
2. 编写 终止条件逻辑。例如，当阶段号达到 5 或注册数为 0 时返回 true。
3. 返回 true 表示 Phaser 进入终止状态，后续的 arriveAndAwaitAdvance() 调用将立即返回，不再阻塞。

Phaser phaser = new Phaser() {
    @Override
    protected boolean onAdvance(int phase, int registeredParties) {
        // 当阶段数达到 3 时，返回 true 终止整个 Phaser
        return phase >= 3 || registeredParties == 0;
    }
};

6. 同步流程状态流转

为了更直观地理解 Phaser 的工作状态，以下是其生命周期的流转逻辑。需要注意的是，Terminated 是终止状态，一旦进入，同步操作将不再阻塞。

通过掌握 Phaser 的动态注册、自动分阶段推进以及分层结构特性，可以在处理复杂的并发多阶段任务时，编写出比 CyclicBarrier 更高效、更灵活的代码。