关于java中CyclicBarrier-创新互联

创新互联www.cdcxhl.cn八线动态BGP香港云服务器提供商，新人活动买多久送多久，划算不套路！

这篇文章将为大家详细讲解有关关于java中CyclicBarrier，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。

1.CyclicBarrier简介

CyclicBarrier 的字面意思是可循环使用（Cyclic）的屏障（Barrier）。它要做的事情是，让一组线程到达一个屏障（也可以叫同步点）时被阻塞，直到最后一个线程到达屏障时，屏障才会开门，所有被屏障拦截的线程才会继续干活。 在JDK中对CyclicBarrier是这样说的“允许一组线程全部等待彼此到达公共屏障点的同步辅助。 循环障碍在涉及必须偶尔彼此等待的固定大小的线程程序中是有用的。屏障称为循环 ，因为它可以在等待线程释放后重新使用”。CountDownLatch的计数器无法被重置；CyclicBarrier的计数器可以被重置后使用，因此它被称为是循环的barrier。

我们先来看一下他的构造方法和使用方式：

构造函数：
    CyclicBarrier(int parties) //其参数表示屏障拦截的线程数量，每个线程调用await方法告
                                 诉CyclicBarrier我已经到达了屏障，然后当前线程被阻塞。

    CyclicBarrier (int parties, Runnable barrierAction) //创建一个新的CyclicBarrier ，
                                当给定数量的参与者（线程）等待它时，它将跳闸，当障碍跳闸时，它
                                将执行 给定的障碍动作(Runnable参数提供)，由最后一个线程进入障碍。

    方法：
    int await()   //在所有参与者都已经在此 barrier 上调用 await 方法之前，将一直等待。
                  方法之前将一直等待,或者超出了指定的等待时间。
    int getNumberWaiting()  //返回当前在屏障处等待的参与者数目。
    int getParties()        //返回要求启动此 barrier 的参与者数目。
    boolean isBroken()      //查询此屏障是否处于损坏状态。
    void reset()            //将屏障重置为其初始状态。

下面我们来看一个小程序了解一下CyclicBarrier的使用方式：

public class CyclicBarrierTest {
  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) {

        }
        System.out.println(Thread.currentThread().getName()+"正在等待...");
      }
    }).start();

    try {
      c.await();
    } catch (Exception e) {

    }
    System.out.println(Thread.currentThread().getName()+"正在等待...");
    System.out.println("人够了，出发吧 当前有 "+c.getParties()+" 个人参与比赛");
  }
}