CyclicBarrier使用及源码分析

• 简介

1、允许一组线程相互等待达到一个公共的障碍点，之后再继续执行
2、跟countDownLatch的区别
    CountDownLatch一般用于某个线程等待若干个其他线程执行完任务之后，它才执行；不可重复使用 
    CyclicBarrier一般用于一组线程互相等待至某个状态，然后这一组线程再同时执行；可重用的

• 案例1

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierDemo {

    public static void main(String[] args) {
        // 指定计数器个数
        CyclicBarrier cyclicBarrier = new CyclicBarrier(8);
        // 创建8个线程
        for (int i = 0; i < 8; i++) {
            int finalI = i;
            new Thread(() -> {
                try {
                    Thread.sleep(finalI * 1000L);
                    System.out.println(Thread.currentThread().getName() + "准备就绪");
                    cyclicBarrier.await();          // 8个线程都准备就绪后
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
                System.out.println("开始比赛");         // 最后8个线程同时进行
            }).start();
        }
    }

}

# 控制台打印结果：
Thread-0准备就绪
Thread-1准备就绪
Thread-2准备就绪
Thread-3准备就绪
Thread-4准备就绪
Thread-5准备就绪
Thread-6准备就绪
Thread-7准备就绪
开始比赛
开始比赛
开始比赛
开始比赛
开始比赛
开始比赛
开始比赛
开始比赛

Process finished with exit code 0

• 源码分析

# 查看CyclicBarrier对象
    public CyclicBarrier(int parties) {      // 当我们new CyclicBarrier对象时，传入个数
        this(parties, null);
    }

# 查看this方法
    public CyclicBarrier(int parties, Runnable barrierAction) {
        if (parties <= 0) throw new IllegalArgumentException();
        this.parties = parties;      // 个数
        this.count = parties;      // 正在等待的个数
        this.barrierCommand = barrierAction;
    }

# 查看count

标签：分析,准备就绪,比赛,Thread,源码,线程,CyclicBarrier,public
来源： https://www.cnblogs.com/chniny/p/16276134.html