java CyclicBarrier同步屏障

Posted 2020-11-18 狗哥

CyclicBarrier的字面意思是可循环使用的屏障，它的主要作用是，让一组线程到达一个屏障时被阻塞，知道最后一个线程到达屏障时，屏障才会打开，所有被屏障拦截的线程才会继续运行。

1、简介：

　　CyclicBarrier默认的构造方法是CyclicBarrier(int parties),其中参数标识屏障拦截的线程数量，每个线程调用await方法告诉CyclicBarrier我已经到达了屏障，然后当前线程被阻塞。

package com.test;

import java.util.concurrent.CyclicBarrier;

public class CiclicBarrierTest {
    
    static CyclicBarrier c = new CyclicBarrier(2);
    
    public static void main(String[] args) {
        new Thread(new Runnable() {
            
            @Override
            public void run() {
                try {
                    c.await();
                } catch (Exception e) {
                    e.printStackTrace();
                }
                System.out.println(1);
            }
        }).start();
        
        try {
            c.await();
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println(2);
    }
}

如果把new CyclicBarrier(2)修改擦new CyclicBarrier(3) 则主线程和子线程会永远等待，因为没有第三个线程去执行await方法。既没有第三个线程到达屏障，所以之前到达屏障的两个线程都不会继续执行。

 

CyclicBarrier还提供一个更高级的构造函数，CyclicBarrier(int parties, Runnable barrier-Action)用于在线程到达屏障时，优先执行barrierAction,方便处理更复杂的业务场景:

package com.test;

import java.util.concurrent.CyclicBarrier;

public class CiclicBarrierTest {
    
    static CyclicBarrier c = new CyclicBarrier(2, new A());
    
    public static void main(String[] args) {
        new Thread(new Runnable() {
            
            @Override
            public void run() {
                try {
                    c.await();
                } catch (Exception e) {
                    e.printStackTrace();
                }
                System.out.println(1);
            }
        }).start();
        
        try {
            c.await();
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println(2);
    }
    
    public static class A implements Runnable {

        @Override
        public void run() {
            System.out.println(3);
        }
        
    }
}
// 结果
3
1
2

 

CyclicBarrier和CountDownLatch的区别:

　　CountDownLatch的计数器只能使用一次，而CyclicBarrier的计数器可以使用reset()方法重置。所以CyclicBarrier能处理更为复杂的业务场景。

　　CyclicBarrier还提供其他有用的方法，比如getNumberWaiting方法可以获得被阻塞的线程数量. isBroken()方法用来了解阻塞的线程是否被中断。