在Java中如何使用Phaser进行多阶段任务同步_Phase多阶段同步技巧

Phaser phaser = new Phaser(1); // 主线程作为控制器先行注册

// 启动多个工作线程
for (int i = 0; i < 3; i++) {
    new Thread(() -> {
        int phase;

        // 阶段一：初始化
        System.out.println(Thread.currentThread().getName() + " 完成初始化");
        phaser.arriveAndAwaitAdvance();

        // 阶段二：数据处理
        phase = phaser.getPhase();
        System.out.println(Thread.currentThread().getName() + " 正在处理数据 (阶段 " + phase + ")");
        simulateWork(500);
        phaser.arriveAndAwaitAdvance();

        // 阶段三：结果汇总准备
        phase = phaser.getPhase();
        System.out.println(Thread.currentThread().getName() + " 提交结果 (阶段 " + phase + ")");
        phaser.arriveAndAwaitAdvance();

    }).start();
}

// 等待所有线程完成第一阶段
phaser.arriveAndAwaitAdvance(); // 阶段0完成
System.out.println("✅ 所有线程已完成初始化");

phaser.arriveAndAwaitAdvance(); // 阶段1完成
System.out.println("✅ 数据处理完成");

phaser.arriveAndAwaitAdvance(); // 阶段2完成
System.out.println("✅ 结果汇总完成");

phaser.arriveAndDeregister(); // 注销主线程，结束控制

new Thread(() -> {
    System.out.println("监控线程：启动");
    phaser.arriveAndAwaitAdvance(); // 第一阶段同步

    System.out.println("监控线程：收集初始状态");
    phaser.arriveAndAwaitAdvance(); // 第二阶段后退出

    phaser.arriveAndDeregister(); // 退出Phaser，不再等待后续阶段
}).start();

try {
    phaser.arriveAndAwaitAdvance();
} catch (Exception e) {
    phaser.forceTermination(); // 触发全局终止
    throw e;
}