java多线程应用_并发工具类之循环屏障(CyclicBarrier)

CyclicBarrier这个类的字面意思是循环屏障，跟CountDownLatch有些像，但不一样。关于CountDownLatch我在该爬虫项目中使用过，没有单独的文章进行讲解。
CyclicBarrier跟CountDownLatch的区别是：
CountDownLatch只计数1次
CyclicBarrier可以通过reset()重置计数，实现更复杂的业务，也会在其等待完毕释放锁后重置计数。
说明：
CyclicBarrier有2个构造
CyclicBarrier(int parties) 设置一个任务的参与数
CyclicBarrier(int parties,Runnable barrierAction) 设置一个任务的参与数和优先执行的barrierAction
步骤：
1、设置任务参与数，每个参与数达到相应阶段后，执行await方法。
2、当最后一个参与者进入await的阶段后，则停止阻塞
注意： barrierAcction屏障动作是由最后一个达到的子线程执行的
 
可以看我下面的代码,以学生去郊游为例，展示了其线程阻塞和可循环使用的功能:

package top.yibobo.test;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierTest {
    public static void main(String[] args) {
        test();
    }
    private static void test() {
        CyclicBarrier cb = new CyclicBarrier(5, () ->
                System.out.println(Thread.currentThread().getId() + "~~大家都到齐了，出发干下件事咯"));
        for (int i = 0; i < 5; i++) {
            new Thread(() -> {
                System.out.println(Thread.currentThread().getId() + " 学生 已达到学校门口");
                await(cb);
                System.out.println(Thread.currentThread().getId() + " 学生 已经坐上 旅游大巴");
                await(cb);
                System.out.println(Thread.currentThread().getId() + " 学生到达景点");
                await(cb);
            }).start();
        }
    }
    private static void await(CyclicBarrier cb){
        try {
            cb.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (BrokenBarrierException e) {
            e.printStackTrace();
        }
    }
}

 
输出语句为:
12 学生 已达到学校门口
13 学生 已达到学校门口
11 学生 已达到学校门口
14 学生 已达到学校门口
15 学生 已达到学校门口
15~~大家都到齐了，出发干下件事咯
15 学生 已经坐上 旅游大巴
13 学生 已经坐上 旅游大巴
14 学生 已经坐上 旅游大巴
11 学生 已经坐上 旅游大巴
12 学生 已经坐上 旅游大巴
12~~大家都到齐了，出发干下件事咯
12 学生到达景点
13 学生到达景点
15 学生到达景点
11 学生到达景点
14 学生到达景点
14~~大家都到齐了，出发干下件事咯触发
 
的确实现了线程等待其他线程完成的功能
注意观察线程ID，可以发现每次触发 barrierAction 屏障动作都是由最后一个线程来执行的