Java Phaser 动态注册参与者并推进阶段同步的实现方法

Java Phaser 适合“参与者数量会变化、任务还要重复经过多个阶段”的并发协调。实现的关键不是让每个线程随意调用 arrive，而是先建立参与者账本：任务开始前调用 register()，阶段完成后调用 arriveAndAwaitAdvance()，任务不再参加后续阶段时调用 arriveAndDeregister()。这三个动作要与任务生命周期成对出现。

先把 Phaser 的参与者账本建起来

下面的结构把主线程作为一个初始 party。每个工作任务提交前注册一次，第一阶段完成后与主线程汇合；工作任务随后执行第二阶段，最终注销自己。这样做的好处是，代码中的“谁在等待”和“谁还会参加下一轮”都能从调用位置看出来。

Phaser phaser = new Phaser(1); // 主线程先注册，负责等待第一阶段
ExecutorService pool = Executors.newFixedThreadPool(4);

for (int i = 0; i  {
        try {
            loadChunk(taskId); // 第一阶段：准备各自的数据
            phaser.arriveAndAwaitAdvance(); // 到达后等待其他已注册任务
            publishChunk(taskId); // 第二阶段：屏障推进后再发布
        } finally {
            phaser.arriveAndDeregister(); // 不再参加后续阶段，必须注销
        }
    });
}

phaser.arriveAndAwaitAdvance(); // 主线程也到达第一阶段
phaser.arriveAndDeregister(); // 主线程完成协调后退出参与者集合
pool.shutdown(); // 关闭线程池，避免资源长期占用

这段代码表达的是静态调用关系，不代表某次机器上的真实运行结果。实际项目还要给 loadChunk 和 publishChunk 增加异常记录、取消传播和结果收集；Phaser 本身不会替你保存这些业务状态。

动态加入与完成退出要成对设计

register() 增加一个 party，返回它加入时的 phase；需要一次加入多个参与者时可以使用 bulkRegister(n)。注册动作应该发生在任务真正进入阶段之前，否则主线程可能已经推进阶段，后来加入的任务就不再属于你以为的那一轮。

任务正常完成后，arriveAndDeregister() 会先报告到达，再把自己从后续阶段的计数中移除。如果任务只完成当前阶段但还要继续下一阶段，用 arrive()；如果到达后要等待其他参与者，则用 arriveAndAwaitAdvance()。不要把“到达”和“注销”混成所有场景都适用的一种调用。

阶段等待的参数与错误边界

排查阶段不推进时，先看三件事：是否漏掉了某个 register()，是否有任务异常返回却没有进入 finally，以及是否把已经注销的任务再次当成 party 调用了到达方法。官方 API 明确指出，未注册 party 调用到达等待属于误用；阶段终止后，注册不会产生正常参与效果，相关方法可能返回负的 phase。

如果等待需要可中断或超时，不要给 arriveAndAwaitAdvance() 硬加业务超时参数，而是拆成“先到达，再调用 awaitAdvanceInterruptibly 的对应形式”，同时设计超时后的注销路径。超时只是等待方放弃，不等于底层工作已经停止，线程池任务仍需单独取消或收口。

把阶段约定写进工程检查清单

• 注册点和任务提交点相邻，避免任务已经开始运行才补注册。
• 工作函数用 try/finally 包住注销，异常路径也要减少参与者数量。
• 主线程是否参加阶段要明确：参加就构造时注册，不参加就只调用等待方法而不要伪造到达。
• 记录每轮 phase、registeredParties 和未处理任务数；这些指标用于定位卡住，不是 Phaser 的替代数据模型。

相关问题

Phaser 和 CountDownLatch 的主要区别是什么？

CountDownLatch 适合一次性倒计数；Phaser 支持重复阶段和动态增减参与者，适用于任务批次会变化的协调场景。

任务异常退出后为什么阶段一直不推进？

常见原因是异常路径没有执行 arriveAndDeregister()，或者任务注册了却没有任何到达调用。把收口放入 finally，再结合 phase 和参与者数量定位。

arriveAndDeregister 可以替代 arriveAndAwaitAdvance 吗？

不能。前者到达后退出，不等待其他参与者；后者到达后等待阶段推进。是否等待取决于任务还需不需要看到这一阶段的统一边界。