CountDownLatch 是 Java 中的一个同步辅助工具类

下面是一个使用 `CountDownLatch` 的案例分析,我们将通过一个简单的示例来展示如何使用 `CountDownLatch` 来同步多个线程的操作。

### 场景描述
假设我们有一个任务,需要从多个数据源(比如多个数据库表或文件)中读取数据,然后进行汇总。为了确保所有数据源的数据都被读取完成,我们可以使用 `CountDownLatch` 来同步这些操作。

### 步骤

1. **初始化 CountDownLatch**:
   设置一个 `CountDownLatch` 对象,其计数器等于需要读取的数据源数量。

   ```java
   int numberOfDataSources = 3; // 假设有3个数据源
   CountDownLatch latch = new CountDownLatch(numberOfDataSources);
   ```

2. **创建并启动线程**:
   为每个数据源创建一个线程,用于读取数据。

   ```java
   for (int i = 0; i < numberOfDataSources; i++) {
       new Thread(new DataSourceReader(i, latch)).start();
   }
   ```

3. **定义任务**:
   实现 `DataSourceReader` 线程任务,用于从特定数据源读取数据,并在完成后调用 `countDown()`。

   ```java
   class DataSourceReader implements Runnable {
       private final int dataSourceNumber;
       private final CountDownLatch latch;

       public DataSourceReader(int dataSourceNumber, CountDownLatch latch) {
           this.dataSourceNumber = dataSourceNumber;
           this.latch = latch;
       }

       @Override
       public void run() {
           try {
               System.out.println("Reading data from data source " + dataSourceNumber);
               // 模拟数据读取操作
               Thread.sleep((long) (Math.random() * 1000));
               System.out.println("Data source " + dataSourceNumber + " finished reading.");
               latch.countDown(); // 数据读取完成,减少计数器
           } catch (InterruptedException e) {
               Thread.currentThread().interrupt();
           }
       }
   }
   ```

4. **等待所有线程完成**:
   在主线程中使用 `await()` 方法等待所有数据源的读取操作完成。

   ```java
   try {
       latch.await(); // 等待所有数据源读取完成
       System.out.println("All data sources have been read.");
       // 继续执行汇总操作
   } catch (InterruptedException e) {
       Thread.currentThread().interrupt();
       System.out.println("Main thread was interrupted.");
   }
   ```

5. **执行后续操作**:
   一旦 `latch.await()` 返回,表示所有数据源的读取操作已经完成,此时可以安全地执行数据汇总或其他后续操作。

### 分析
在这个案例中,`CountDownLatch` 用于确保主线程在所有数据源的读取操作完成之前不会继续执行。这保证了数据的一致性和完整性。每个数据源的读取线程在完成其任务后通过调用 `countDown()` 来减少 `CountDownLatch` 的计数。当计数达到零时,`await()` 方法返回,主线程可以安全地继续执行。

这个案例展示了 `CountDownLatch` 在处理需要同步多个线程操作的场景中的实用性,特别是在需要等待多个异步任务完成时。
 

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

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

相关文章

使用jdk11运行javafx程序和jdk11打包jre包含javafx模块

我们都知道jdk11是移除了javafx的,如果需要使用javafx,需要单独下载。 这就导致我们使用javafx开发的桌面程序使用jdk11时提示缺少javafx依赖。但这是可以通过下面的方法解决。 一,使用jdk11运行javafx程序 我们可以通过设置vmOptions来使用jdk11运行javafx程序 1,添加j…

【RAG KG】GraphRAG开源:查询聚焦摘要的图RAG方法

前言 传统的 RAG 方法在处理针对整个文本语料库的全局性问题时存在不足&#xff0c;例如查询&#xff1a;“数据中的前 5 个主题是什么&#xff1f;” 对于此类问题&#xff0c;是因为这类问题本质上是查询聚焦的摘要&#xff08;Query-Focused Summarization, QFS&#xff09…

嵌入式单片机,两者有什么关联又有什么区别?

在开始前刚好我有一些资料&#xff0c;是我根据网友给的问题精心整理了一份「嵌入式的资料从专业入门到高级教程」&#xff0c; 点个关注在评论区回复“666”之后私信回复“666”&#xff0c;全部无偿共享给大家&#xff01;&#xff01;&#xff01;使用单片机是嵌入式系统的…

iOS 国际化语言第一语言不支持时候默认语言强转英文

对bundle扩展 直接贴代码 .h文件 // // NSBundleKdLocalBundle.h // QooCam // // Created by bob bob on 2023/9/8.//#import <Foundation/Foundation.h>NS_ASSUME_NONNULL_BEGINinterface NSBundle (KdLocalBundle)end interface KdLocalBundle:NSBundleend interf…

CurrentHashMap巧妙利用位运算获取数组指定下标元素

先来了解一下数组对象在堆中的存储形式【数组长度&#xff0c;数组元素类型信息等】 【存放元素对象的空间】 Ma 基础信息实例数据内存填充Mark Word,ClassPointer,数组长度第一个元素第二个元素固定的填充内容 所以我们想要获取某个下标的元素首先要获取这个元素的起始位置…

软件工程常见知识点

下午收到字节日常实习的面试邀请&#xff0c;希望这次能有一个好的表现。言归正传&#xff0c;邮件中提到这些问题&#xff0c;我这边借了书并查了网上的资料&#xff0c;做一个提前准备。 软件工程核心概念&#xff1a; 如何从一个需求落实到一个系统设计&#xff1f; 经过我…

c++ primer plus 第15章友,异常和其他:异常,15.3.7 其他异常特性

c primer plus 第15章友&#xff0c;异常和其他&#xff1a;异常,15.3.7 其他异常特性 c primer plus 第15章友&#xff0c;异常和其他&#xff1a;异常,15.3.7 其他异常特性 文章目录 c primer plus 第15章友&#xff0c;异常和其他&#xff1a;异常,15.3.7 其他异常特性 15.…

Sorted Set 类型命令(命令语法、操作演示、命令返回值、时间复杂度、注意事项)

Sorted Set 类型 文章目录 Sorted Set 类型zadd 命令zrange 命令zcard 命令zcount 命令zrevrange 命令zrangebyscore 命令zpopmax 命令bzpopmax 命令zpopmin 命令bzpopmin 命令zrank 命令zscore 命令zrem 命令zremrangebyrank 命令zremrangebyscore 命令zincrby 命令zinterstor…

线程池案例

秒杀 需求 10个礼物20个客户抢随机10个客户获取礼物&#xff0c;另外10无法获取礼物 任务类 记得给共享资源加锁 public class MyTask implements Runnable{// 礼物列表private ArrayList<String> gifts ;// 用户名private String username;public MyTask( String user…

android Dialog全屏沉浸式状态栏实现

在Android中&#xff0c;创建沉浸式状态栏通常意味着让状态栏背景与应用的主题颜色一致&#xff0c;并且让对话框在状态栏下面显示&#xff0c;而不是浮动。为了实现这一点&#xff0c;你可以使用以下代码片段&#xff1a; 1、实际效果图&#xff1a; 2、代码实现&#xff1a;…

揭秘GPT-4o:未来智能的曙光

引言 近年来&#xff0c;人工智能&#xff08;AI&#xff09;的发展突飞猛进&#xff0c;尤其是自然语言处理&#xff08;NLP&#xff09;领域的进步&#xff0c;更是引人注目。在这一背景下&#xff0c;OpenAI发布的GPT系列模型成为了焦点。本文将详细探讨最新的模型GPT-4o&a…

Unity海面效果——6、反射和高光

Unity引擎制作海面效果 大家好&#xff0c;我是阿赵。 上一篇的结束时&#xff0c;海面效果已经做成这样了&#xff1a; 这个Shader的复杂程度已经比较高了&#xff1a; 不过还有一些美中不足的地方。 1、 海平面没有反射到天空球 2、 在近岸边看得到水底的部分&#xff0c;水…

JVM调优:深入理解与实战指南

引言 Java虚拟机&#xff08;JVM&#xff09;作为Java应用程序的运行环境&#xff0c;其性能直接影响到应用程序的响应速度、吞吐量和稳定性。JVM调优是Java开发者必须掌握的一项关键技能&#xff0c;它能够帮助我们更好地利用系统资源&#xff0c;提升应用程序的性能。本文将…

一些关于C++的基础知识

引言&#xff1a;C兼容C的大部分内容&#xff0c;但其中仍有许多小细节的东西需要大家注意 一.C的第一个程序 #include <iostream> using namespace std;int main() {cout << "hello world!" << endl;return 0; } 第一次看这个是否感觉一头雾水…

数据挖掘——matplotlib

matplotlib概述 Mat指的是Matlab&#xff0c;plot指的是画图&#xff0c;lib即library&#xff0c;顾名思义&#xff0c;matplotlib是python专门用于开发2D图表的第三方库&#xff0c;使用之前需要下载该库&#xff0c;使用pip命令即可下载。 pip install matplotlib1、matpl…

elasticsearch SQL:在Elasticsearch中启用和使用SQL功能

❃博主首页 &#xff1a; 「码到三十五」 &#xff0c;同名公众号 :「码到三十五」&#xff0c;wx号 : 「liwu0213」 ☠博主专栏 &#xff1a; <mysql高手> <elasticsearch高手> <源码解读> <java核心> <面试攻关> ♝博主的话 &#xff1a…

服务注册Eureka

目录 一、背景 1、概念 2、CAP 理论 3、常见的注册中心 二、Eureka 三、搭建 Eureka Server 1、搭建注册中心 四、服务注册 五、服务发现 六、Eureka 和 Zooper 的区别 一、背景 1、概念 远程调用就类似于一种通信 例如&#xff1a;当游客与景区之间进行通信&…

代码随想录算法训练营第六十三天 | prim算法、kruskal算法、复习

53. 寻宝 — prim算法 题目链接&#xff1a;https://kamacoder.com/problempage.php?pid1053 文档讲解&#xff1a;https://programmercarl.com/kamacoder/0053.%E5%AF%BB%E5%AE%9D-prim.html 思路 本题是最小生成树的模板题&#xff0c;最小生成树可以使用 prim算法&#xf…

bash shell 重定向输入和输出

shell 提供的重定向操作符 操作符作用>将命令的输出发到一个文件中如果文件存在&#xff0c;则新的文件数据会覆盖已经存在的文件>>将命令的输出追加到一有文件如果文件不存在&#xff0c;则创建新的文件<将文件内容重定向到命令<<内联输入重定向(inline in…

Xubuntu24.04之设置高性能模式两种方式(二百六十一)

简介: CSDN博客专家,专注Android/Linux系统,分享多mic语音方案、音视频、编解码等技术,与大家一起成长! 优质专栏:Audio工程师进阶系列【原创干货持续更新中……】🚀 优质专栏:多媒体系统工程师系列【原创干货持续更新中……】🚀 优质视频课程:AAOS车载系统+AOSP…