码迷,mamicode.com
首页 > 编程语言 > 详细

有10个线程, 主线程怎么等待10个线程执行完之后才执行

时间:2021-06-10 17:37:56      阅读:0      评论:0      收藏:0      [点我收藏+]

标签:线程阻塞   throws   await   对象   否则   简单   bsp   countdown   辅助   

 

  • CountDownLatch是一个同步辅助工具,用于使一个或多个线程等待(即阻塞)知道一组在其他线程中的任务结束。
  • CountDownLatch必须用给定的count(一个int类型的大于等于0的值)进行初始化。调用await方法将使线程阻塞,直到当前计数(count值)由于countdown方法的调用而达到零,此后所有等待的线程被释放并且任何后续调用await方法也会立即返回。CountDownLatch被设计为只触发一次,即Count值在运行过程中无法重置。如果需要重置计数的版本,可以考虑使用CyclicBarrier.
  • CountDownLatch是一种通用的同步工具。 CountDownLatch可以被认为是一个简单的on/off锁存器或门:所有线程调用await方法等待开关打开,直到countDown方法被调用打开开关为止。 创建一个CountDownLatch,指定count的值为N,那么这个CountDownLatch对象可以让一个线程等待其他N个线程结束(调用countDown方法即认为结束),或者调用了这个CountDownLatch的countDown方法N次。

 

测试代码如下:

public class ThreadWait {
    public static void main(String[] args) throws InterruptedException {
        ExecutorService exector = Executors.newFixedThreadPool(5);
        int threadNumber = 13;
        final CountDownLatch countDownLatch = new CountDownLatch(threadNumber);
        for (int i = 0; i < threadNumber; i++) {
            final int threadID = i;
            exector.execute(
                    () -> {
                        try {
                            Thread.sleep(2000);
                            System.out.println(String.format("threadID:[%s] finished!!", threadID));
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        } finally {
                            countDownLatch.countDown();  //这个不管是否异常都需要数量减,否则会被堵塞无法结束
                        }
                    }
            );
        }
        countDownLatch.await();//保证之前的所有的线程都执行完成,才会走下面的
        System.out.println(countDownLatch.getCount());
        System.out.println("main thread finished!!");
    }
}
结果为:

threadID:[0]finished!!
        threadID:[1]finished!!
        threadID:[4]finished!!
        threadID:[3]finished!!
        threadID:[2]finished!!
        threadID:[9]finished!!
        threadID:[8]finished!!
        threadID:[5]finished!!
        threadID:[6]finished!!
        threadID:[7]finished!!
        threadID:[10]finished!!
        threadID:[11]finished!!
        threadID:[12]finished!!
        0
        main thread finished!!

 

有10个线程, 主线程怎么等待10个线程执行完之后才执行

标签:线程阻塞   throws   await   对象   否则   简单   bsp   countdown   辅助   

原文地址:https://www.cnblogs.com/-flq/p/14867493.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!