1 概述

CyclicBarrier允许一组线程相互等待，直到到达某个公共的屏障点这组线程才继续执行。在涉及一组固定大小的线程的程序当中，这组线程必须相互等待，这个时候CyclicBarrier就显得非常有用了，由于Barrier（栅栏）在释放线程后可以从新使用，所以Barrier被称为Cyclic(循环)Barrier（栅栏）。

2 示例

下面我们来看看CyclicBarrier是如何使用的。

public class CyclicBarrierTest {
    private static CyclicBarrier cyclicBarrier = new CyclicBarrier(5, () -> System.out.println("all thread complete"));

    public static void main(String[] args) {
        for (int i = 0; i <5 ; i++) {
            new Thread(() -> {
                try {
                    System.out.println(Thread.currentThread().getId()+" running!");
                    cyclicBarrier.await();
                    System.out.println(Thread.currentThread().getId()+" running again!");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }).start();
        }
        System.out.println("main begin");
    }
}

程序执行的结果：

main begin
14 running!
15 running!
13 running!
17 running!
16 running!
all thread complete
16 running again!
17 running again!
13 running again!
15 running again!
14 running again!

从上面的运行结果我们可以看出来5个线程等待直到所有线程等待完成的时候再继续开始执行。

3 函数说明

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

4 与CountDownLatch的区别

上面就是对CyclicBarrier使用的介绍，接下来将进行源码的分析。