Phaser 是 Java 并发包中支持动态增减参与者、多阶段复用的同步器，适用于分阶段并行任务；通过 arriveAndAwaitAdvance() 推进阶段，register()/arriveAndDeregister() 动态扩缩容，可与 ForkJoinPool 协同提升吞吐量。
Phaser 是 Java 并发包（java.util.concurrent）中专为多阶段、动态参与线程设计的同步器，比 CountDownLatch 和 CyclicBarrier 更灵活，尤其适合分阶段、成员可变的大规模并行任务。它的核心优势在于支持动态注册/注销参与者、可复用、能嵌套阶段，并天然适配 fork-join 模式或分层工作流。
用 Phaser 管理分阶段并行任务
当任务天然具有多个执行阶段（如：预处理 → 计算 → 合并 → 输出），且每阶段需等待所有参与者完成才进入下一阶段时，Phaser 是最优选。它通过 arriveAndAwaitAdvance() 实现“到达并等待升级”，自动推进到下一阶段编号（phase number），无需重置或新建实例。
- 初始化时可指定初始参与者数（如
new Phaser(n)），也可在运行时调用register()动态加入新线程 - 每个阶段内，所有参与者调用
arriveAndAwaitAdvance()；最后一个到达者触发 phase 自增，其余线程被唤醒继续下一阶段 - 避免在循环中重复 new Phaser，应复用同一实例——Phaser 本身是线程安全且可重入的
动态扩缩容：支持运行时增减线程
大规模任务常伴随负载变化（如部分子任务失败重试、弹性扩容、分片动态分配），Phaser 允许任意时刻增删参与者，而不会破坏当前阶段同步语义。
deep-java-review
下载
Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...
- 新增线程调用
phaser.register()，立即计入下一阶段的等待计数 - 已注册线程可通过
phaser.arriveAndDeregister()主动退出，此后不再参与后续阶段的 await - 注意：deregister 不影响当前阶段——退出仅在下个 phase 生效；若需立即脱离，应在 arrive 前判断并跳过 await
组合使用 ForkJoinPool 提升吞吐量
Phaser 与 ForkJoinPool 配合，能高效支撑数万级细粒度任务的协同调度。典型模式是：主 Phaser 控制全局阶段，各 fork 分支持有子 Phaser 或共享父 Phaser，按需同步局部结果。
立即学习“Java免费学习笔记（深入）”；
- 推荐将 Phaser 作为外部协调器，ForkJoinTask 内部不直接阻塞，而是用
phaser.arrive()（非 await）上报进度，由少量守卫线程统一调用awaitAdvance(phase) - 避免在 compute() 中频繁调用
arriveAndAwaitAdvance()——这会阻塞工作线程，降低并行度；更适合用异步通知 + 阶段轮询机制 - 可为不同层级任务创建父子 Phaser 关系（通过构造时传入 parent），实现树状同步结构，减少全局竞争
规避常见陷阱与性能提示
Phaser 功能强大，但误用易引发死锁、活锁或性能退化。关键点在于理解其状态机模型和线程生命周期绑定逻辑。
- 不要在 synchronized 块内调用 arrive/await 方法——Phaser 内部已做充分并发控制，额外同步反而导致锁竞争
- 监听 phase 变化可用
onAdvance(int phase, int registeredParties)回调，但该方法在同步上下文中执行，务必保持轻量（禁止 I/O、长耗时计算） - 监控活跃参与者数：调用
getRegisteredParties()或getArrivedParties()辅助调试，但生产环境慎用——它们有微小开销，高频调用影响扩展性 - 大规模场景下，建议搭配虚线程（Java 21+）使用：每个逻辑任务绑定一个虚拟线程 + register 到 Phaser，内存与调度开销远低于平台线程
