JUC工具类 CountDownLatch详解

news/2025/3/9 10:39:03/文章来源:https://www.cnblogs.com/y54y5666/p/18757181

Java并发编程中的 java.util.concurrent包提供了多种并发编程工具类,其中 CountDownLatch是一个非常有用的类,它允许一个或多个线程等待一系列指定操作的完成。

CountDownLatch简介

CountDownLatch是一个同步辅助类,它允许一个线程或多个线程等待,直到其他线程的一组操作执行完成。CountDownLatch有一个计数器,该计数器初始化为一个正整数,表示需要等待的事件数量。CountDownLatch提供了 countDown方法来表示一个事件已经发生了,每调用一次,计数器的值就减一。当计数器的值变为零时,所有等待的线程就会被释放,这意味着它们可以继续执行。

CountDownLatch的用法

CountDownLatch的常用于可以被拆分为一组独立子任务的场景,每个子任务执行完成后调用 countDown方法。这常见于并行处理任务或等待初始化操作完成。

示例场景

假设我们有一个任务,需要等待一个服务的多个组件完成初始化后才能启动。我们可以使用 CountDownLatch来确保所有组件都初始化完成后,主任务才开始执行。

CountDownLatch的具体实现

以下是一个 CountDownLatch的简单实现例子:

import java.util.concurrent.CountDownLatch;public class ServiceStarter {public static void main(String[] args) {final CountDownLatch latch = new CountDownLatch(3); // 假设有3个服务组件for (int i = 1; i <= 3; i++) {final int componentId = i;new Thread(() -> {try {// 模拟服务组件初始化Thread.sleep((long) (Math.random() * 1000));System.out.println("Component " + componentId + " has started.");} catch (InterruptedException e) {Thread.currentThread().interrupt();} finally {latch.countDown();}}).start();}try {latch.await(); // 等待所有服务组件启动System.out.println("All services are up, application is starting now!");} catch (InterruptedException e) {Thread.currentThread().interrupt();}}
}
 
 

上述代码中,我们启动了三个线程分别表示三个需要初始化的服务组件。每个线程启动后,就开始执行初始化操作,完成后调用 countDown方法。主线程中的 latch.await()会一直阻塞,直到计数器的值减到0。

CountDownLatch的核心方法

CountDownLatch 提供了两个关键方法:

  1. public void await() :调用该方法的线程会被阻塞,直到计数器的值减到零。
  2. public void countDown() :该方法会使计数器的值减一。当计数器的值减到零时,所有因 await()方法阻塞的线程会被释放。

CountDownLatch的特点

  1. 计数器的值只能在初始化时设置,之后无法被重置。
  2. 计数器到零之后,所有的 await方法调用立即返回,后续的 countDown调用不会有任何影响。
  3. 不同于 CyclicBarrierCountDownLatch无法重复使用。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/894984.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

ACK 通过sls收集pod日志

常见的收集方式 filebeat->kafka->logstash->es阿里云ACK日志收集 ack->sls 这里要说的是我们传统意义上是通过收集pod或者node节点上的 .log日志文件进行收集日志,在ack里面可以不用通过收集.log的方式进行日志收集。具体的操作看下面的步骤1 开始操作吧 1.1 ACK…

GreatSQL5.7 与 8.0 对 DATE 非法值处理方式不同

GreatSQL5.7 与 8.0 对 DATE 非法值处理方式不同 一、问题描述 1. 问题现象 当分别通过LOAD DATA LOCAL INFILE和INSERT导入非法的 DATE 字段数据时,在5.7.21和 8.0.25使用LOAD DATA LOCAL会报一个Warning,数据异常但可以插入成功,而且实际插入的数据跟用户计划插入的不同,…

Hyper-V的安装过程自动化程度较高,但要了解每个安装步骤背后的原理

Hyper-V的安装过程确实具有较高的自动化程度,但了解每个安装步骤背后的原理对于确保安装的成功以及后续的维护和管理至关重要。以下是对Hyper-V安装过程中每个关键步骤及其原理的详细解析:一、准备工作 步骤:检查系统要求、备份数据、关闭不必要的程序。 原理: 系统要求:确…

牛客题解 | 拼凑三角形

牛客题库题解题目 题目链接 题解 题目难度:简单 知识点:数学逻辑 思路: 三角形成立的条件:1.为了更简便的判断三角形是否成立,将三个数由小到大进行排序放入a[3]中,只需要满足a[0]+a[1]&amp;gt;a[2]即可。(两个较小的数相加大于第三个数)。 2.若a[0]+a[1]&amp;…

内网环境部署Deepseek+Dify,构建企业私有化AI应用

0.简介 公司为生产安全和保密,内部的服务器不可连接外部网络,为了可以在内网环境下部署,采用的方案为ollama(Docker)+Dify(Docker Compose),方便内网环境下迁移和备份,下文将介绍部署的全部过程。 1.镜像拉取 镜像拉取为准备工作,因服务器在内网环境,需要先在可以连接外…

牛客题解 | 拍照队形

牛客题库题解题目 题目链接 题解 题目难度:简单难度 知识点:数学逻辑 分析:主要考虑输出格式,由于N=3k+1,那么前K行每行输出2个字符,后k+1行输出1个字符。对于前k行,第一行:第一列输出字符,空格数为m=2*k-1,在输出第二个字符;第二行:先空格1,输出字符,空格m-=2个(…

电动后尾门控制器PLGM

经纬恒润平台化的电动尾门控制器PLGM可为不同的后尾门应用场合提供解决方案,目前已为众多客户配套量产。 经纬恒润平台化的电动尾门控制器PLGM(Power Lift Gate Module,PLGM)可为不同的后尾门应用场合提供解决方案,目前已为众多客户配套量产。主要功能车门电动打开…

CentOS 磁盘扩容lvm(虚拟机环境)

fdisk -l 查看磁盘情况对新增加的硬盘进行分区,使用fdisk命令创建和维护分区表。 fdisk /dev/vda 输入p:查看已分区数量(有两个 /dev/vda1 /dev/vda2) 输入n(new partition):新增加一个分区 输入p(parimary partition):分区类型选择为主分区 输入分区号3(partition …

Vue 自定义指令封装实现防抖 防止按钮暴力点击

本来项目前期没有做按钮防抖功能 快结束时才想起来 然后一个个写太慢了 然后就想着封装一下 vue3:新建directive.jsexport default {//自定义节流操作preventReClick: {mounted(el, binding) {el.addEventListener(click, () => {if (!el.disabled) {el.disabled = truesetT…

3.6 CW 模拟赛 T3. 列表

思路题意 有一个长度为 2n+12 \times n + 12n+1 的整数列表 aaa 初始恰好为 1∼2n+11 \sim 2 \times n + 11∼2n+1 的排列; 有一个集合 S\mathbb{S}S 初始为空, 进行 n+1n + 1n+1 次操作, 第 iii 次操作如下:111. 选择列表最中间位置的数第 n+2−in + 2 - in+2−i 个数, 从列表…

Navicat 操作 MySql 修改表结构时保存后直接卡死无反应问题

一、问题如下:在Navicat中调整表结构,添加新的字段。之后保存的时候就一直显示正在保存,等了一会儿也一直没有反应,点关闭也停止不了保存操作,就一直卡着。二、问题解决1、查看当前的进程列表: show processlist会发现有等待的进程:这些进程状态为Waiting for table met…

SAP 3M胶带:行业解决方案的革新者

SAP 3M胶带:行业解决方案的革新者 在胶带加工行业,SAP 3M胶带凭借其卓越的性能和广泛的应用领域,成为了众多企业的首选。而SAP与3M的结合,更是将科技与创新完美融合,为行业带来了全新的解决方案。库存管理痛点解决 胶带加工行业的多变性使得库存管理成为了一大痛点。然而,…