phaser 通过阶段感知、显式注册/注销和非阻塞协同实现多阶段异步任务的一致性，要求所有已注册未注销参与者调用 arrive 或 arriveandawaitadvance 后才推进阶段，支持动态增减参与者及 onadvance 校验。
Phaser 在多阶段异步任务中保持执行一致性，核心不是“强制所有线程步调一致”，而是通过阶段感知 + 显式注册/注销 + 非阻塞协同，让不同任务在关键汇合点达成逻辑同步。它不依赖线程生命周期绑定，也不要求所有任务走完全相同路径，而是靠每个参与者主动声明“我参与本阶段”和“我已完成本阶段”，由 Phaser 统一推进阶段号。
阶段推进必须由所有已注册参与者共同触发
Phaser 的一致性根基在于：当前阶段不会结束，直到所有已注册且尚未注销的参与者都调用 arrive 或 arriveAndAwaitAdvance。这与 CyclicBarrier 的“等齐人数”不同——Phaser 等的是“已注册者中未完成者归零”。
- 启动前用
phaser.register()明确声明参与，哪怕任务是 CompletableFuture 异步启动的 - 每个阶段结束时，必须调用
arriveAndAwaitAdvance()（需同步等待）或arrive()+ 后续显式等待（如awaitAdvance(phase)） - 若某任务中途失败或退出，应调用
arriveAndDeregister()，避免拖住整个阶段
异步任务需桥接 Phaser 生命周期与回调时机
CompletableFuture 本身不阻塞，但 Phaser 的阶段推进需要同步信号。二者协同的关键是：把 arriveAndDeregister() 放在异步任务的终态回调里，而不是任务体内部。
- 不要在
supplyAsync的 lambda 里直接调用arriveAndAwaitAdvance()—— 这会阻塞 ForkJoinPool 线程 - 应在
whenComplete、handle或exceptionally中调用phaser.arriveAndDeregister()，确保无论成功或失败都释放栅栏计数 - 主线程或协调线程在关键节点调用
phaser.awaitAdvance(currentPhase)，而非allOf(...).join()，避免被单个失败任务阻断
动态参与者让一致性适配运行时变化
一致性不是静态的“3个线程永远一起走3个阶段”，而是动态的“当前活跃参与者共同决定阶段何时结束”。这特别适合模块化、可插拔的异步流程。
- 新增一个风控校验子任务？只需在提交前
phaser.register()，无需修改主流程或重置 Phaser - 某个下游服务临时不可用，对应任务快速失败并
arriveAndDeregister()，其余任务照常推进到下一阶段 - 用
getRegisteredParties()和getArrivedParties()可实时判断阶段是否卡住，便于熔断或告警
onAdvance 提供阶段级一致性校验点
重写 onAdvance(int phase, int registeredParties) 是保障逻辑一致性的最后一道防线。它在每个阶段切换前被调用，返回 true 可终止 Phaser，返回 false 才进入下一阶段。
- 可在 phase == 1 时检查关键数据是否全部就位，缺失则返回
true中止后续阶段 - 在 phase == 2 时统计失败率，超阈值则拒绝进入收尾阶段
- 结合日志或监控指标（如 Micrometer 注册的
phaser.phase.count），实现可观测的一致性验证
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
