第76题JAVA高级技术-多线程10（闭锁CountDownLatch）

Posted 2022-06-06 小虚竹

回城传送–》《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();
        
    

多学一个知识点

CountDownLatch原理及注意事项

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

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

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

四、推荐专栏

《JAVA从零到壹》

《JAVA筑基100例》

五、示例源码下载

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

筑基76