532
CyclicBarrier的使用
CyclicBarrier的使用
标签（空格分隔）： Java多线程
简介
CyclicBarrier的字面意思是可循环使用(Cyclic)的屏障(Barrier)。CyclicBarrier的作用是让一组线程之间相互等待，任何一个线程到达屏障点后就阻塞，直到最后一个线程到达，才都继续往下执行。个人理解：CyclicBarrier可以看成是一道大门或者关卡，先到的线程会被阻塞在大门口，直到最后一个线程到达屏障时，大门才被打开，所有被阻塞的线程才会继续干活。就像是朋友聚餐，只有最后一个朋友到达时，才会开吃！
屏障(Barrier)
CyclicBarrier 的构造函数可以传入一个整数，其含义是屏障可拦截的线程数，每个线程都可调用await方法告诉CyclicBarrier“我已经到达了屏障前”，CyclicBarrier内部是执行+1操作，一旦屏障前阻塞的线程数等于构造函数传入的可拦截线程数时，所有被阻塞的线程都将被唤醒，继续往下执行。
常用API
//parties表示屏障前可阻塞的线程数，当阻塞的线程数到达parties时，屏障被打开，所有阻塞的线程将会被唤醒
public CyclicBarrier(int parties);
// 此构造方法不同于上面的是在屏障被打开时将优先执行barrierAction，方便处理更负责的业务场景
public CyclicBarrier(int parties, Runnable barrierAction) ;
// 等待屏障的打开
public int await() throws InterruptedException,BrokenBarrierException ;
//等待屏障的打开 超时会抛出 TimeoutException
public int await(long timeout, TimeUnit unit) throws
InterruptedException,
BrokenBarrierException,
TimeoutException ;
// 返回在屏障前等待的线程数
public int getNumberWaiting() ;
// 获取 当前屏障初始化时 可阻塞的线程数
public int getParties() ；
/**
* 作用:
* 1. 查询此屏障是否处于损坏状态。
* 产生损坏状态的原因:
* 1. 由于超时或者屏障重置(reset)
* 2. 某个屏障操作抛出异常
*/
public boolean isBroken() ;
使用举例
模拟 聚餐场景
public class CyclicBarrierTest {
public static void main(String[] args) throws Exception{
ExecutorService service = Executors.newFixedThreadPool(3) ;
CyclicBarrier cyclicBarrier = new CyclicBarrier(3,()->{
System.out.println("全都到了 【开吃!】");
}) ;
for(int i = 0 ; i < 3 ; i++) {
final int number = i ;
service.execute(()->{
try {
System.out.println("编号:" + number + "开始出发 【去聚餐】");
Thread.sleep((int)(Math.random() * 10000));
System.out.println("编号:" + number + " 【到达聚餐地点】");
cyclicBarrier.await();
} catch (Exception e) {
e.printStackTrace();
}
});
}
service.shutdown();
}
}
循环使用
循环使用指的是在大门被打开后，可以再次关闭，再次让之前指定数目的线程在屏障前阻塞等待，然后再次打开大门。
方法reset()的作用就是重置屏障，循环使用。
但是在调用reset()方法后，如果有线程在屏障前等待，则await方法会抛出BrokenBarrierException异常。这个异常通常发生在当某个线程在等待本CylicBarrier时。https://blog.csdn.net/chenchaofuck1/article/details/51598504
常用API
// 将屏障重置为其初始化状态即重置为构造函数传入的parties值。
public void reset();
最后更新：2017-07-27 14:32:48