同步工具类 Phaser

淩亂°似流年 2022-09-10 11:08 113阅读 0赞

Phaser是CyclicBarrier和CountDownLatch的加强版，jdk1.7增加的一个类  
Phaser代替CountDownLatch：主线程等待5个worker线程运行结束

Phaser phaser = new Phaser(5);
            System.out.println("线程启动");
            Random random = new Random();
            for (int i = 0; i < 5; i++) {
        
                new Thread("线程-" + (i + 1)) {
        
                    @Override
                    public void run() {
        
                        System.out.println(getName() + " - 开始运行");
                        try {
        
                            Thread.sleep(random.nextInt(1000));
                        } catch (InterruptedException e) {
        
                            e.printStackTrace();
                        }
                        System.out.println(getName() + " - 运行结束");
                        phaser.arrive();
                    }
                }.start();
            }
            //主线程阻塞，等待worker线程运行结束
            phaser.awaitAdvance(0);
            System.out.println("线程运行结束");

Phaser代替CyclicBarrier：5个worker线程需要同时进入下一个阶段

Phaser phaser = new Phaser(5);
            Random random = new Random();
            for (int i = 0; i < 5; i++) {
        
                new Thread(() -> {
        
                    try {
        
                        System.out.println(Thread.currentThread().getName() + " - 开始向公司出发");
                        Thread.sleep(random.nextInt(1000));
                        System.out.println(Thread.currentThread().getName() + " - 已经到达公司");
                        // 到达同步点，等待其他线程
                        phaser.arriveAndAwaitAdvance();
                        System.out.println(Thread.currentThread().getName() + " - 开始笔试");
                        Thread.sleep(random.nextInt(1000));
                        System.out.println(Thread.currentThread().getName() + " - 笔试结束");
                        // 到达同步点，等待其他线程
                        phaser.arriveAndAwaitAdvance();
                        System.out.println(Thread.currentThread().getName() + " - 开始面试");
                        Thread.sleep(random.nextInt(1000));
                        System.out.println(Thread.currentThread().getName() + " - 面试结束");
                    } catch (InterruptedException e) {
        
                        e.printStackTrace();
                    }
                }, "线程-" + (i + 1)).start();
            }

Phaser可以再运行期间动态调整同步线程个数

多个Phaser可以形成一个树状结构

//用一个parent来存放父Phaser 
    private final Phaser parent;

//root节点本来有2个参与者，它有2个子Phaser(c1,c2)，所以它的参与者变成了2+2=4个
    Phaser root = new Phaser(2); 
    //c1节点有3个参与者，它有1个子Phaser(c3)，所以它的参与者变成了3+1=4个
    Phaser c1 = new Phaser(root, 3); 
    //没有子Phaser，参与者2个
    Phaser c2 = new Phaser(root, 2); 
    //0个参与者
    Phaser c3 = new Phaser(c1, 0);

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAQ2hyaXNfQ2hyaXNf_size_20_color_FFFFFF_t_70_g_se_x_16]

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAQ2hyaXNfQ2hyaXNf_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/58b590d791d54daf8419f0be4d2f1eea.png