Java 中 Phaser 与 CountDownLatch 在多阶段任务中的选择

以我的经验来看，Phaser 更适合多阶段任务，而 CountDownLatch 仅适用于一次性等待全部完成；Phaser 支持阶段递增、动态注册/注销线程、阶段号获取与自定义阶段切换逻辑，而 CountDownLatch 无法重置、无阶段概念、也难以追踪多阶段状态。

从实战角度讲，Phaser 在多阶段任务中显然是更合适的选择——而 CountDownLatch，基本派不上用场。

CountDownLatch 无法支撑多阶段推进

CountDownLatch 本质上是一个一次性的倒计时器。一旦计数归零，它就彻底失效了，既不能重置，也无法回退，更谈不上感知“阶段”这个概念。它只能回答一个最简单的问题：“所有任务是不是都干完了？”——但你完全没法区分“第一阶段完成”和“第二阶段完成”。一旦 await() 方法返回，整个协调过程就算结束了。如果要搞下一阶段，只能新建一个 CountDownLatch，结果就是逻辑被割裂、状态信息丢失、异常处理也困难重重。

• 每个新阶段都得手动创建新实例，线程的注册与注销也需要额外管理
• 你没法知道当前到底处于第几个逻辑阶段，日志、超时、熔断这些统统缺乏上下文
• 某个阶段中途失败了，也很难优雅地终止后续阶段，容易造成资源滞留

Phaser 天然建模阶段生命周期

Phaser 的核心思想，说白了就是「阶段（phase）」。每次调用 arriveAndAwaitAdvance()，当前参与者完成本阶段并阻塞等待全体就绪，Phaser 会自动递增阶段号（从 0 开始），然后进入下一阶段。这个编号是全局、单调且可读的，直接对应业务流程中的“解析→校验→聚合”等环节。

• getPhase() 可以实时获取当前阶段号，用于日志标记、阶段级的超时控制，或者有条件地跳过某些阶段
• 各阶段可以动态注册不同数量的线程，比如：解析阶段用 8 个线程，校验阶段因为数据过滤只需要 5 个
• 某个线程可以在中间阶段退出（调用 arriveAndDeregister()），完全不影响其他线程继续推进

实际协作模式差异明显

在数据清洗、模型训练、游戏初始化这类典型的多阶段场景中，协作模式并不是“所有任务做完再一起走”，而是“每个阶段大家集体迈一步”。CountDownLatch 在这种场景下会被迫退化为多个独立门闩的串联，而 Phaser 提供的是一个带编号的自动扶梯：

• 主线程先调用 phaser.register() 占个位，充当阶段协调者
• 每个工作线程完成本阶段后，统一调用 arriveAndAwaitAdvance() —— 不是各自 countDown，而是共同抬升阶段
• 可以重写 onAdvance(int phase, int registeredParties)：在阶段切换的瞬间做清理、统计，或者判断是否应该终止（比如 phase == 3 且数据异常率超过 5%，就返回 true 强制结束）

简单对比一句话定位

CountDownLatch 适合“等全部干完”，Phaser 适合“一起分步干”。只要任务存在明确的阶段性跃迁、阶段之间有依赖、参与者可能变化，那就别想着用 CountDownLatch 来替代 Phaser 了。