首页 > 编程语言 > 详细

CountDownLatch在多线程中的使用

时间:2021-09-11 21:17:47      阅读:33      评论:0      收藏:0      [点我收藏+]

两种常用的使用方式

1、主线程中开启多个子线程,所有子线程执行完后再执行主线程,多个线程同时运算,某些情况下可以提高效率

CountDownLatch countDownLatch = new CountDownLatch(5);
        for (int i = 0; i < 5; i++) {
            final int index = i;
            new Thread(() -> {
                try {
                    Thread.sleep(30000 + ThreadLocalRandom.current().nextInt(1000));
                    System.out.println("finish" + index + Thread.currentThread().getName());
                    countDownLatch.countDown();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }).start();
        }
        System.out.println("主线程开始等待30秒");
        countDownLatch.await(10, TimeUnit.SECONDS);// 主线程在阻塞,当计数器==0或者等待超时,就唤醒主线程往下执行。
        System.out.println("主线程:在所有任务运行完成后,进行结果汇总");

结果如下

技术分享图片

 

如果 countDownLatch.await();不传参数则先执行所有子线程,子线程都完成才完成主线程

 

2、子线程进行等待,等主线程发信号所有子线程开始执行

CountDownLatch countDownLatch = new CountDownLatch(1);
        for (int i = 0; i < 5; i++) {
            new Thread(() -> {
                try {
                    //准备完毕……运动员都阻塞在这,等待号令
                    countDownLatch.await();
                    String parter = "【" + Thread.currentThread().getName() + "】";
                    System.out.println(parter + "开始执行……");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }).start();
        }

        Thread.sleep(2000);// 裁判准备发令
        System.out.println("准备执行");
        countDownLatch.countDown();// 发令枪:执行发令

打印结果如下

技术分享图片

 

CountDownLatch在多线程中的使用

原文:https://www.cnblogs.com/wscw/p/15252698.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!