在Java中如何使用Phaser实现线程循环等待_Phase循环同步技巧

import java.util.concurrent.Phaser;

public class PhaseCycleExample {
    public static void main(String[] args) {
        Phaser phaser = new Phaser();

        // 启动3个工作线程
        for (int i = 0; i < 3; i++) {
            new Thread(new Worker(phaser)).start();
            phaser.register(); // 注册线程
        }
    }

    static class Worker implements Runnable {
        private final Phaser phaser;

        Worker(Phaser phaser) {
            this.phaser = phaser;
        }

        @Override
        public void run() {
            int phase;
            
            // 执行3个阶段
            for (int i = 0; i < 3; i++) {
                phase = phaser.getPhase();
                System.out.println("Thread " + Thread.currentThread().getName() +
                        " 进入阶段 " + phase);

                // 模拟工作
                try { Thread.sleep(500); } catch (InterruptedException e) {}

                // 等待所有线程完成当前阶段
                phaser.arriveAndAwaitAdvance();
                
                System.out.println("Thread " + Thread.currentThread().getName() +
                        " 完成阶段 " + phase);
            }

            System.out.println("Thread " + Thread.currentThread().getName() + " 结束");
        }
    }
}

if (i == 1) {
    System.out.println("Thread exiting after phase 1");
    phaser.arriveAndDeregister(); // 退出后续阶段
    break;
}