CountDownLatch使用

CountDownLatch是JAVA提供在java.util.concurrent包下的一个辅助类。

内部有一个计数器

  1. 计数器的操作是原子操作,即同时只能有一个线程去操作这个计数器。
  2. CountDownLatch通过构造函数传入计数器的初始化值
  3. 调用者可以通过调用CounDownLatch对象的cutDown()方法,来使计数减1
  4. 如果某线程调用了CountDownLatch对象上的await()方法,那么此调用线程将一直阻塞在这里,直到别的线程通过cutDown方法,将计数减到0,才可以继续执行

一个使用示例

我们假设在生产线上要生产一台电脑(由主板、显示器、内存、显卡、CPU、键盘、鼠标、机箱8个部分组成),电脑的各部件由不同的工作人员生产完成,最后在生产线上把各部件组装完成一台电脑

public class Worker implements Runnable {
    
    private static final Random random = new Random();
    
    private String spareParts;
    
    private CountDownLatch countDownLatch;
    public Worker(String spareParts,CountDownLatch countDownLatch){
        this.spareParts = spareParts;
        this.countDownLatch = countDownLatch;
    }
    public void run() {
        try {
            Thread.sleep(random.nextInt(10000));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("完成部件["+spareParts+"]生产!!");
        countDownLatch.countDown();
    }
}
public class ProductionLine {

    public static void main(String[] args) throws InterruptedException {
        System.out.println("开始生产电脑......");
        CountDownLatch countDownLatch = new CountDownLatch(8);
        //主板、显示器、内存、显卡、CPU、键盘、鼠标、机箱
        new Thread(new Worker("主板", countDownLatch)).start();
        new Thread(new Worker("CPU", countDownLatch)).start();
        new Thread(new Worker("内存", countDownLatch)).start();
        new Thread(new Worker("显示器", countDownLatch)).start();
        new Thread(new Worker("显卡", countDownLatch)).start();
        new Thread(new Worker("电源", countDownLatch)).start();
        new Thread(new Worker("键盘", countDownLatch)).start();
        new Thread(new Worker("鼠标", countDownLatch)).start();
        
        countDownLatch.await();//等待,直到所有的部件都生产出来
        
        System.out.println("利用各个部件组装一台电脑,完成生产!!!"); 
    }
}

结果输出

开始生产电脑......
完成部件[电源]生产!!
完成部件[显卡]生产!!
完成部件[显示器]生产!!
完成部件[CPU]生产!!
完成部件[主板]生产!!
完成部件[键盘]生产!!
完成部件[内存]生产!!
完成部件[鼠标]生产!!
利用各个部件组装一台电脑,完成生产!!!

在多线程协作工作时,当有线程需要等待其他线程完成某个操作,才能往下执行时就可以用到此类进行协调处理

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • CountDownLatch使用 CountDownLatch是java中的一个同步工具类.用于对线程的阻塞和唤醒...
    jack4c阅读 1,691评论 0 0
  • 正常情况下,每个子线程完成各自的任务就可以结束了。不过有的时候,我们希望多个线程协同工作来完成某个任务,这时就涉及...
    野梦M阅读 510评论 0 2
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,087评论 19 139
  • 人的生活方式有两种, 第一种方式是像草一样活着, 你尽管活着,每年还在成长, 但是你毕竟是一棵草, 你吸收雨露阳光...
    上官曙光阅读 501评论 0 0