CountDownLatch的两种常用场景

2023-10-30

CountDownLatch的两种使用场景

先来看看 CountDownLatch 的源码注释;

/**
 * A synchronization aid that allows one or more threads to wait until
 * a set of operations being performed in other threads completes.
 *
 * @since 1.5
 * @author Doug Lea
 */
public class CountDownLatch {
}

描述如下:它是一个同步工具类,允许一个或多个线程一直等待,直到其他线程运行完成后再执行。

通过描述,可以清晰的看出,CountDownLatch的两种使用场景:

  • 场景1:让多个线程等待
  • 场景2:和让单个线程等待。
场景1 让多个线程等待:模拟并发,让并发线程一起执行

为了模拟高并发,让一组线程在指定时刻(秒杀时间)执行抢购,这些线程在准备就绪后,进行等待(CountDownLatch.await()),直到秒杀时刻的到来,然后一拥而上;
这也是本地测试接口并发的一个简易实现。

在这个场景中,CountDownLatch充当的是一个发令枪的角色;
就像田径赛跑时,运动员会在起跑线做准备动作,等到发令枪一声响,运动员就会奋力奔跑。和上面的秒杀场景类似,代码实现如下:

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);// 裁判准备发令
countDownLatch.countDown();// 发令枪:执行发令

运行结果:

【Thread-0】开始执行……
【Thread-1】开始执行……
【Thread-4】开始执行……
【Thread-3】开始执行……
【Thread-2】开始执行……

我们通过CountDownLatch.await(),让多个参与者线程启动后阻塞等待,然后在主线程 调用CountDownLatch.countdown(1) 将计数减为0,让所有线程一起往下执行;
以此实现了多个线程在同一时刻并发执行,来模拟并发请求的目的。

场景2 让单个线程等待:多个线程(任务)完成后,进行汇总合并

很多时候,我们的并发任务,存在前后依赖关系;比如数据详情页需要同时调用多个接口获取数据,并发请求获取到数据后、需要进行结果合并;或者多个数据操作完成后,需要数据check;
这其实都是:在多个线程(任务)完成后,进行汇总合并的场景。

代码实现如下:

CountDownLatch countDownLatch = new CountDownLatch(5);
for (int i = 0; i < 5; i++) {
    final int index = i;
    new Thread(() -> {
        try {
            Thread.sleep(1000 + ThreadLocalRandom.current().nextInt(1000));
            System.out.println("finish" + index + Thread.currentThread().getName());
            countDownLatch.countDown();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }).start();
}

countDownLatch.await();// 主线程在阻塞,当计数器==0,就唤醒主线程往下执行。
System.out.println("主线程:在所有任务运行完成后,进行结果汇总");

运行结果:

finish4Thread-4
finish1Thread-1
finish2Thread-2
finish3Thread-3
finish0Thread-0
主线程:在所有任务运行完成后,进行结果汇总

在每个线程(任务) 完成的最后一行加上CountDownLatch.countDown(),让计数器-1;
当所有线程完成-1,计数器减到0后,主线程往下执行汇总任务。

示例源码:https://github.com/ljheee/JavaConcurrencyInPractice/blob/master/src/main/java/com/ljheee/juc/CountDownLatchUsage.java

从上面两个例子的代码,可以看出 CountDownLatch 的API并不多;

  • CountDownLatch的构造函数中的count就是闭锁需要等待的线程数量。这个值只能被设置一次,而且不能重新设置;

  • await():调用该方法的线程会被阻塞,直到构造方法传入的 N 减到 0 的时候,才能继续往下执行;

    调用了await()进行阻塞等待的线程,它们阻塞在Latch门闩/栅栏上;只有当条件满足的时候(countDown() N次,将计数减为0),它们才能同时通过这个栅栏;以此能够实现,让所有的线程站在一个起跑线上。

  • countDown():使 CountDownLatch 计数值 减 1;

CountDownLatch 工作原理

CountDownLatch是通过一个计数器来实现的,计数器的初始值为线程的数量;
调用await()方法的线程会被阻塞,直到计数器 减到 0 的时候,才能继续往下执行;
countDown()方法则是将计数器减1;

在CountDownLatch的构造函数中,指定的线程数量,只能指定一次;由于CountDownLatch采用的是减计数,因此当计数减为0时,计数器不能被重置。
这是和CyclicBarrier的一个重要区别。

CountDownLatch 的源码在JUC并发工具中,也相对算是简单的;
底层基于 AbstractQueuedSynchronizer 实现,CountDownLatch 构造函数中指定的count直接赋给AQS的state;每次countDown()则都是release(1)减1,最后减到0时unpark阻塞线程;这一步是由最后一个执行countdown方法的线程执行的。
而调用await()方法时,当前线程就会判断state属性是否为0,如果为0,则继续往下执行,如果不为0,则使当前线程进入等待状态,直到某个线程将state属性置为0,其就会唤醒在await()方法中等待的线程。

CountDownLatch与Thread.join

CountDownLatch的作用就是允许一个或多个线程等待其他线程完成操作,看起来有点类似join() 方法,但其提供了比 join() 更加灵活的API。
CountDownLatch可以手动控制在n个线程里调用n次countDown()方法使计数器进行减一操作,也可以在一个线程里调用n次执行减一操作。
而 join() 的实现原理是不停检查join线程是否存活,如果 join 线程存活则让当前线程永远等待。所以两者之间相对来说还是CountDownLatch使用起来较为灵活。

CountDownLatch与CyclicBarrier

CountDownLatch和CyclicBarrier都能够实现线程之间的等待,只不过它们侧重点不同:

  • CountDownLatch一般用于一个或多个线程,等待其他线程执行完任务后,再才执行
  • CyclicBarrier一般用于一组线程互相等待至某个状态,然后这一组线程再同时执行
    另外,CountDownLatch是减计数,计数减为0后不能重用;而CyclicBarrier是加计数,可置0后复用。

更多CyclicBarrier的内容,请见下篇。

阅读原文:https://mp.weixin.qq.com/s/RhK_BrYrooGGYbN5OvyXow


推荐阅读

本文首发于 公众号 架构道与术(ToBeArchitecturer),欢迎关注、学习更多干货~
在这里插入图片描述

推荐阅读
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

CountDownLatch的两种常用场景 的相关文章

  • java程序有多少种结束方式?

    我知道使用 System exit 0 可以结束一个java程序 例如 如果我有一个JFrame窗口 它会关闭并结束程序 但我想知道还有多少其他方法 可以关闭它并结束程序 包括发生错误时 程序会被关闭 JFrame也会被关闭吗 添加到其他答
  • 如何以编程方式使用包含多列的 where-in 子句执行 PostgreSQL 查询?

    我的查询是这样的 select from plat customs complex where code t code s in 01013090 10 01029010 90 它在 psql 控制台中运行良好 我的问题是如何在客户端代码中
  • 如何在 Android 应用程序中隐藏 Flutterwave API 密钥

    我正在构建一个 Android 应用程序 目前正在将 Flutterwave 集成到我的应用程序中以进行支付 建议我永远不要将 Flutterwave API 密钥放在我的应用程序上 那么我该如何隐藏这些键呢 我正在使用 Retrofit
  • Java LostFocus 和 InputVerifier,按反向制表符顺序移动

    我有一个 GUI 应用程序 它使用 InputVerifier 在产生焦点之前检查文本字段的内容 这都是很正常的 然而 昨天发现了一个问题 这似乎是一个错误 但我在任何地方都找不到任何提及它的地方 在我将其报告为错误之前 我想我应该问 我在
  • 什么是内部类的合成反向引用

    我正在寻找应用程序中的内存泄漏 我正在使用的探查器告诉我寻找这些类型的引用 但我不知道我在寻找什么 有人可以解释一下吗 Thanks Elliott 您可以对 OUTER 类进行合成反向引用 但不能对内部类实例进行合成 e g class
  • 无法使用 datastax java 驱动程序通过 UDT 密钥从 cassandra 检索

    我正在尝试使用用户定义的类型作为分区键将对象存储在 cassandra 中 我正在使用 datastax java 驱动程序进行对象映射 虽然我能够插入到数据库中 但无法检索该对象 如果我更改分区键以使用非 udt 例如文本 我就能够保存和
  • 我对线程失去了理智

    我想要这个类的对象 public class Chromosome implements Runnable Comparable
  • Java AES 256 加密

    我有下面的 java 代码来加密使用 64 个字符密钥的字符串 我的问题是这会是 AES 256 加密吗 String keyString C0BAE23DF8B51807B3E17D21925FADF273A70181E1D81B8EDE
  • Android 认为我没有关闭数据库!为什么?

    我有一个 SQLiteDatabase 数据成员 我在 onCreate 中初始化它 并在 onPause onStop 和 onDestroy 中调用 close 它在 onResume 中重新初始化 它似乎运行得很好 但当我查看调试器时
  • IntelliJ Idea:将简单的 Java servlet(无 JSP)部署到 Tomcat 7

    我尝试按照教程进行操作here http wiki jetbrains net intellij Creating a simple Web application and deploying it to Tomcat部署 servlet
  • UseCompressedOops JVM 标志有什么作用以及何时应该使用它?

    HotSpot JVM 标志是什么 XX UseCompressedOops我应该做什么以及什么时候使用它 在 64 位 Java 实例上使用它 与不使用它 时 我会看到什么样的性能和内存使用差异 去年大多数 HotSpot JVM 都默认
  • 使用 Proguard 通过 Dropbox.com 库混淆 Android 应用程序

    我刚刚创建了一个需要 Dropbox com API 库的 Android 应用程序 我现在尝试在 发布 模式下构建应用程序 并希望在代码上运行混淆器以对其进行混淆 但是 每当我尝试运行 Proguard 时 都会收到以下错误 Progua
  • Joshua Bloch 的构建器设计模式有何改进?

    早在 2007 年 我就读过一篇关于 Joshua Blochs 所采用的 构建器模式 的文章 以及如何修改它以改善构造函数和 setter 的过度使用 特别是当对象具有大量属性 其中大部分属性是可选的 时 本文对此设计模式进行了简要总结
  • Lombok 不适用于 Eclipse Neon

    我下载了lombok jar lombok 1 16 14 jar 并将其放入我的下载中 然后我点击这个 jar 执行正确地识别了我的 MacOS 上的 Eclipse 实例 然后我选择了我想要的实例 Lombok也在pom xml中指定
  • java实现excel价格、收益率函数[关闭]

    就目前情况而言 这个问题不太适合我们的问答形式 我们希望答案得到事实 参考资料或专业知识的支持 但这个问题可能会引发辩论 争论 民意调查或扩展讨论 如果您觉得这个问题可以改进并可能重新开放 访问帮助中心 help reopen questi
  • titledBorder 标题中的图标

    您好 是否可以在 titledBorder 的标题中放置一个图标 例如以下代码 import java awt GridLayout import javax swing JFrame import javax swing JLabel i
  • 使用 Apache 允许 Glassfish 和 PHP 在同一服务器中协同工作

    是否可以建立从 Java 到 php 文件的桥梁 我有一个用 Java 编写的应用程序 我需要执行http piwik org http piwik org 这是用 PHP 编写的 在服务器中 我正在运行 PHP 但无法从浏览器访问 php
  • 确定 JavaFX 中是否消耗了事件

    我正在尝试使用 JavaFX 中的事件处理来做一些非滑雪道的事情 我需要能够确定手动触发事件后是否已消耗该事件 在以下示例中 正确接收了合成鼠标事件 但调用 Consumer 不会更新该事件 我对此进行了调试 发现 JavaFX 实际上创建
  • Java 中清除嵌套 Map 的好方法

    public class MyCache AbstractMap
  • Java 的“&&”与“&”运算符

    我使用的示例来自 Java Herbert Schildt 的完整参考文献 第 12 版 Java 是 14 他给出了以下 2 个示例 如果阻止 第一个是好的 第二个是错误的 因此发表评论 public class PatternMatch

随机推荐

  • ipa-apk.cn/dbl.html,ComicBook/package-lock.json at master · liyuechun/ComicBook · GitHub

    name comicbook version 0 0 1 lockfileVersion 1 dependencies abab version 1 0 3 resolved https registry npmjs org abab ab
  • C++基础08---this,static

    1 this 1 在我们利用某个类对象调用成员函数时 编译器将这个对象的地址传递给该成员函数中的一个隐藏的this形参 2 任何对类成员变量的直接访问都被看作是通过this做隐式调用 3 this指针只能在成员函数中使用 全局函数 静态函数
  • 程序员版孔乙己

    互联网的格局 是和别处不同的 都是格子衫 稀疏的头发 双肩包 男 写代码的人 傍午傍晚散了工 每每三两人 背着手 沿着软件园溜达一圈 倘肯花点钱 便还会走到星巴克 买一杯咖啡 那样便能再多摸几分钟的鱼 我从十九岁起 便在软件园的星巴克打工
  • 代码随想录一刷-Day08

    Offer58 II 左旋转字符串 使用中间数组很容易 public String reverseLeftWords String s int n if n 0 s null s length 0 return s 使用中间数组 char
  • vRealize Operations Manager 安装部署

    前话 关于VROPS好不好用的问题 我只想说 谁用谁知道 早用早HAPPY 官方描述有 VMware vRealize Operations是一个高度可扩展 可扩展且直观的操作平台 可集中管理软件定义数据中心 SDDC 它可根据业务或运营意
  • 【PCIe】5: PCIe DBI (Date Bus Interface)

    目录 1 DBI 2 CDM 3 ELBI 3 1 EP 的排布 3 2 RC对应空间排布 1 DBI DBI Data Bus Interface You can use this interface to locally access
  • 如何保证消息队列的顺序性?

    面试题 如何保证消息的顺序性 面试官心理分析 其实这个也是用 MQ 的时候必问的话题 第一看看你了不了解顺序这个事儿 第二看看你有没有办法保证消息是有顺序的 这是生产系统中常见的问题 面试题剖析 我举个例子 我们以前做过一个 mysql b
  • 二十七、python学习之前端(十):Vue入门

    一 vue简介 1 vue简介 Vue js是前端三大新框架 Angular js React js Vue js之一 Vue js目前的使用和关注程度在三大框架中稍微胜出 并且它的热度还在递增 Vue js可以作为一个js库来使用 也可以
  • 安装QT5.4.0

    安装 Qt 第一步 到官网https download qt io new archive qt 5 4 5 4 0 qt opensource linux x64 5 4 0 run下载 Qt 安装包 此处本人安装的是 qt openso
  • Java算法——地图单点坐标判断是否存在于某个区域

    Java算法 地图单点坐标判断是否存在于某个区域 在气象项目中 需要我们通过网格数据 来识别分析天气 之后判断该天气在具体什么省市县 而提醒该地方将要发生什么天气 而每个省市县都有自己得经纬度范围 而且不规则性 我们如何将从网格上面识别得天
  • 初识uni-app

    初识uni app 跨平台开发的神器 本文将为大家介绍uni app 一款强大的跨平台App开发框架 我们将探讨其特点 优势以及如何快速上手开发一个简单的uni app应用 1 什么是uni app uni app是由DCloud公司研发的
  • DSP相关笔记_1:LaunchXL-F28379D的简单教程系列(一)GPIO输出

    LaunchXL F28379D的简单教程系列 一 GPIO输出 本文分为函数库和寄存器两种方法 注 这是本人关于Ti的C2000系列的学习笔记 所用工具有官方的开发软件CCS10版本 帮助文库以及函数库软件controlSUITE 硬件部
  • QGLViewer编译过程

    libQGLViewer 2 7 1 官网下载 http libqglviewer com installWindows html Qt5 11 0 编译器 MSVC2017 64bit 解压后的样子 1 编译QGLViewer 打开QGL
  • python列表输出去掉引号,如何从列表输出中删除逗号和引号

    很难把这些引号和逗号从我的列表中去掉 SHOWN BELOW IN THE SECOND PART OF MY CODE OUTPUT 我需要从输出中剥离所有 我一直在我的team variable上尝试rstrip 但它给了我这个错误 在
  • jQuery.validate.js API

    jQuery validate js API Name Type validate options Returns Validator 验证所选的FORM valid Returns Boolean 检查是否验证通过 rules Retur
  • C 输入 & 输出

    C 语言把所有的设备都当作文件 所以设备 比如显示器 被处理的方式与文件相同 以下三个文件会在程序执行时自动打开 以便访问键盘和屏幕 表1 标准文件 标准文件 文件指针 标准输入 stdin 标准输出 stdout 标准错误 stderr
  • JavaScript的常用继承方法

    原型链继承 让一个构造函数的原型 prototype 是另一个构造函数的实例 优点 写法方便简洁 容易理解 缺点 对象实例共享所有继承的属性和方法 不能传递参数 function Person age this name 张三 this a
  • Global对象的理解与认识

    JavaScript 中有一个特殊的对象 称为全局对象 Global Object 它及其所有属性都可以在程序的任何地方访问 即全局变量 在浏览器端的 JavaScript 中 通常 window 是全局对象 而 Node js 中的全局对
  • 【目标检测】31、Alpha-IoU: A Family of Power Intersection over Union Losses for Bounding Box Regression

    文章目录 一 背景 二 方法 2 1 Alpha IoU 的提出 2 2 Alpha IoU 的特性 三 效果 论文 Alpha IoU A Family of Power Intersection over Union Losses fo
  • CountDownLatch的两种常用场景

    CountDownLatch的两种使用场景 先来看看 CountDownLatch 的源码注释 A synchronization aid that allows one or more threads to wait until a se