JUC-CyclicBarrier基础篇

1.概念

CyclicBarrier顾名思义叫做循环栅栏，它是多个线程之间的同步工具类。它的作用就是会让所有线程都等待完成后才会继续下一步行动。它与JUC另一个多个线程之间的同步工具类CountDownLatch类似，但是功能比CountDownLatch更加强大(它们之间的区别请看JUC-CountDownLatch基础篇)
场景举例：比如现在有一个门，门上有5把锁，此时有五个人需要通过这扇门，它们每个人只能打开一把锁，所以执行情况是，来一个人开一把锁，然后等着，直到最后一个人来了打开了最后一把锁。此时5个人才可以通过这扇门。

2.常用方法

CyclicBarrier 提供了一些常用的方法：

3.例子

下面代码演示5个线程它们之间相互等待对方的事情都干完了，才接着执行下面的事情

public class CyclicBarrierTest {
    public static void main(String[] args) throws BrokenBarrierException, InterruptedException {
        //设置parties的初始值为5
        CyclicBarrier cyclicBarrier = new CyclicBarrier(5, new Runnable() {
            @Override
            //栅栏被打开了后所要做的事情
            public void run() {
                System.out.println("通过了栅栏");
            }
        });
        for (int i = 0; i < 5; i++) {
            new Thread("thread"+i){
                @Override
                public void run() {
                    try {
                        System.out.println("线程：" + Thread.currentThread().getName() + "的事情干完了，等待其他的线程都干完它们的事情，才接着干下面的事情");
                        //每调用一次await方法,parties值先减1，如果parties不为0，则阻塞住。
                        //直到parties的值为0，栅栏被打开,才继续往下执行
                        //返回值await表示当前线程调用了await()后，parties当前的值是多少
                        int await = cyclicBarrier.await();
                        System.out.println("线程：" + Thread.currentThread().getName() + "  通过了栅栏,接着干后面的事情");
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } catch (BrokenBarrierException e) {
                        e.printStackTrace();
                    }

                }
            }.start();
            System.out.println();
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

执行结果: