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时。http://blog.csdn.net/chenchaofuck1/article/details/51598504

常用API

// 将屏障重置为其初始化状态即重置为构造函数传入的parties值。 public void reset(); 相关资源：敏捷开发V1.0.pptx