Java并发工具：Phaser实现分阶段同步技巧

Java并发工具Phaser以其动态注册/注销参与者、多轮多阶段灵活同步的能力，成为CountDownLatch和CyclicBarrier的理想替代方案——尤其适用于MapReduce式计算、插件化线程动态启停、多批次压测等场景；它支持运行时调整参与方、细粒度阶段控制与轻量级阻塞，但需警惕常见陷阱：如未显式register就arrive导致异常、onAdvance()中执行阻塞操作引发死锁、ForkJoinPool内递归提交任务的风险，以及阶段号溢出对业务逻辑的影响，掌握这些关键细节才能真正释放Phaser在复杂并发流程中的强大潜力。

Phaser比CountDownLatch和CyclicBarrier更适合哪些场景

当你需要动态增减参与同步的线程数，或者任务明显分多轮、每轮内部还有子阶段（比如“所有线程加载数据→部分线程校验→全部线程汇总”），Phaser才是更自然的选择。它不像CountDownLatch那样初始化后无法重置，也不像CyclicBarrier那样要求每次参与方数量固定——Phaser支持运行时注册/注销参与者，还能通过arriveAndDeregister()让线程在某阶段退出同步。

常见错误现象：Phaser构造时传了初始参与者数，但后续没调用register()就直接arrive()，导致IllegalStateException: not registered；或者误以为arriveAndAwaitAdvance()会自动注册，其实不会。

• 使用场景：MapReduce式分阶段计算、测试中模拟多批次并发压测、插件化系统中动态加载/卸载工作线程
• 参数差异：new Phaser(int parties)设的是初始注册数，不是最大数；真正控制参与关系的是register()和deregister()
• 性能影响：相比CyclicBarrier，Phaser在高竞争下有更细粒度的锁分离，但频繁调用register()/deregister()会带来少量额外开销

如何正确注册、抵达并推进阶段

核心是理解Phaser的两个状态动作：注册（加入当前阶段队列）和抵达（声明本线程完成当前阶段）。它们不耦合——注册只做一次（或按需多次），抵达则每阶段都要调用。

典型错误：在循环里反复register()却不deregister()，导致阶段计数持续累积，arriveAndAwaitAdvance()永远等不到预期人数。

• 启动阶段：主线程先new Phaser(1)（自己算一个参与者），再让工作线程调用phaser.register()
• 每阶段结束：线程调用phaser.arriveAndAwaitAdvance()（抵达+阻塞等待全体完成）
• 中途退出：某线程完成第2阶段后不再参与后续，就在第2阶段末尾调用phaser.arriveAndDeregister()
• 注意：arrive()只抵达不等待，适合“发信号但不卡住”的场景，比如监控线程上报进度

监听阶段变化：onAdvance()的触发时机与陷阱

onAdvance(int phase, int registeredParties)在每个阶段结束、所有参与者都抵达后被调用，返回true表示终止同步，后续arrive*调用将立即返回（不再阻塞）。

容易踩的坑：onAdvance()在Phaser内部锁下执行，**不能在里面调用任何可能阻塞或依赖其他Phaser操作的方法**，否则会死锁。例如，在onAdvance()里调用另一个Phaser.arriveAndAwaitAdvance()就是典型反模式。

• 常用做法：在onAdvance()里检查phase值判断是否到最终阶段（如phase == 3），然后返回true终止
• 调试技巧：在onAdvance()里打印registeredParties，能快速发现是否有线程忘记register()或提前deregister()
• 兼容性注意：Java 7引入Phaser，但onAdvance()的registeredParties参数在Java 8才加入，旧版本只能靠getRegisteredParties()查实时数

Phaser和ForkJoinPool配合时的线程模型问题

当把Phaser用在ForkJoinTask中（比如每个子任务抵达阶段），要注意ForkJoinPool的工作线程是共享且复用的。一个任务调用arriveAndAwaitAdvance()阻塞后，该线程会被挂起，但池中其他任务仍可能被同一线程执行——这本身没问题；但如果你在onAdvance()里提交新任务到同一个ForkJoinPool，而此时池已满负荷，就可能造成隐式递归等待，甚至死锁。

• 安全做法：在onAdvance()中避免向当前ForkJoinPool提交任务；改用Executors.newCachedThreadPool()或明确指定外部Executor
• 性能提示：Phaser本身无内部线程，所有阻塞由调用线程承担，所以它和ForkJoinPool组合时，实际并发度取决于池大小，而非Phaser配置
• 调试线索：如果发现阶段推进明显变慢且CPU不高，大概率是onAdvance()里做了同步I/O或锁等待

最常被忽略的一点：Phaser的阶段号（phase）从0开始，每完成一轮自增1，但它不是循环的——一旦达到Integer.MAX_VALUE，下一次会变成Integer.MIN_VALUE。如果业务逻辑依赖阶段号做模运算（比如phase % 3），必须自己处理溢出，不能假设它永远递增。

到这里，我们也就讲完了《Java并发工具：Phaser实现分阶段同步技巧》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！