CyclicBarrier使用及源码分析

2022-05-16 11:01:31 阅读：159 来源： 互联网

标签：分析准备就绪比赛 Thread 源码线程 CyclicBarrier public

简介

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

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

CyclicBarrier使用及源码分析