回城传送–》《JAVA筑基100例》

零、前言

​ 今天是学习 JAVA语言 打卡的第76天，每天我会提供一篇文章供群成员阅读（ 不需要订阅付钱 ），读完文章之后，按解题思路，自己再实现一遍。在小虚竹JAVA社区 中对应的 【打卡贴】打卡，今天的任务就算完成了。

​ 因为大家都在一起学习同一篇文章，所以有什么问题都可以在群里问，群里的小伙伴可以迅速地帮到你，一个人可以走得很快，一群人可以走得很远，有一起学习交流的战友，是多么幸运的事情。

​ 学完后，自己写篇学习报告的博客，可以发布到小虚竹JAVA社区 ，供学弟学妹们参考。

​ 我的学习策略很简单，题海策略+ 费曼学习法。如果能把这100题都认认真真自己实现一遍，那意味着 JAVA语言 已经筑基成功了。后面的进阶学习，可以继续跟着我，一起走向架构师之路。

一、题目描述

题目：jdk5.0在java.util.concurrent包中提供了CountDownLatch，它是一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。

闭锁可以延迟线程的进度直到其到达终止状态，闭锁可以用来确保某些活动直到其他活动都完成才继续执行：

1）确保某个计算在其需要的所有资源都被初始化之后才继续执行；

2）确保某个服务在其他依赖的所有其他服务都已经启动之后才启动；

3）等待直到某个操作所有参与者都准备就绪在继续执行。

实现：使用CountDownLatch实现一个等5个任务完成后，才进行下边的任务。

二、解题思路

CountDownLatch提供了一个await方法，该方式用于等待前边countdownlatch所统计的线程完成后，才可以向下执行，否则一直等待。

创建一个类：CoutDownLatchTest

在main方法中new CountDownLatch(5)初始化的开启计数个数,为0才会跳出等待。

获取当前的时间戳

Long start=System.currentTimeMillis();

新建个内部类：MyCallable ，内部类implements Runnable

内部类里的run()方法做一个简单的1~100的加法，结束时使用countDownLatch.countDown();释放计数。

主线程中新增5个线程去跑，然后使用 countDownLatch.await();等待5个任务完成后，才进行下边任务

下边任务：

打印总耗时。

三、代码详解

CoutDownLatchTest

package com.xiaoxuzhu;

import java.util.concurrent.CountDownLatch;

/**
 * Description: 
 *
 * @author xiaoxuzhu
 * @version 1.0
 *
 * <pre>
 * 修改记录:
 * 修改后版本	        修改人		修改日期			修改内容
 * 2022/5/15.1	    xiaoxuzhu		2022/5/15		    Create
 * </pre>
 * @date 2022/5/15
 */
public class CoutDownLatchTest {
    public static void main(String[] args) {
        Long start=System.currentTimeMillis();

        // 线程数
        //new CountDownLatch(5)初始化的开启计数个数,为0才会跳出等待
        CountDownLatch countDownLatch=new CountDownLatch(5);
        MyCallable myCallable=new MyCallable(countDownLatch);

        for (int i = 0; i < 5; i++) {
            new Thread(myCallable).start();
        }

        try {
            // 等待所有任務完成后，才進行下邊的任務。
            countDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        Long end=System.currentTimeMillis();
        System.out.println("耗时："+(end-start)+" ms");
    }
}

class MyCallable implements Runnable {
    private CountDownLatch countDownLatch;

    public MyCallable(CountDownLatch countDownLatch) {
        this.countDownLatch = countDownLatch;
    }

    public void run() {
        try {
            int sum = 0;
            for (int i = 0; i <= 100; i++) {
                sum += i;
            }
            System.out.println(sum);
        } finally {
            countDownLatch.countDown();
        }
    }

}


  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
  
21
  
22
  
23
  
24
  
25
  
26
  
27
  
28
  
29
  
30
  
31
  
32
  
33
  
34
  
35
  
36
  
37
  
38
  
39
  
40
  
41
  
42
  
43
  
44
  
45
  
46
  
47
  
48
  
49
  
50
  
51
  
52
  
53
  
54
  
55
  
56
  
57
  
58
  
59
  
60
  
61
  
62
  
63
 

多学一个知识点

CountDownLatch原理及注意事项

1）CountDownLatch初始化的开启计数个数必须要到达0时，才会跳出等待，这个是等待跳过的一个依赖；

2）如果该统计个数初始化的值，大于调用countDown()的次数，就会导致线程一直等待状态

3）它实现的原理，就是给CountDownLatch一个初始化统计数，在监控的线程内部操作完成时，调用countDown()函数，调用一次则初始化监控统计数递减1。当调用了CountDownLatch的实例的await函数时，实际上是一直监控是否初始化监控统计数到达0否，一旦到达0，则跳出等待。进行await等待，向下执行。

四、推荐专栏

《JAVA从零到壹》

《JAVA筑基100例》

五、示例源码下载

关注下面的公众号，回复筑基+题目号

筑基76

文章来源: xiaoxuzhu.blog.csdn.net，作者：小虚竹，版权归原作者所有，如需转载，请联系作者。

原文链接：xiaoxuzhu.blog.csdn.net/article/details/125027238