当前位置: 首页 > news >正文

多线程CountDownLatch使用

1、简介

CountDownLatch是一个同步工具类,用来携调多个线程之间的同步,它是是使用一个计数器进行实现的,计数器初始值为线程数量。当每一个线程完成自己任务后,计数器的值就会减1。当计数器的值为0时,表示所有的线程都已经完成一些任务,然后再CountDownLatch上等待的线程就可以恢复执行下来的任务。


CountDownLatch主要有两个方法:countDown()await()
countDown()方法用于使计数器减一,其一般是执行任务的线程调用,
await()方法是调用该方法的线程处于等待状态,其一般是主线程调用。
countDown()方法并没有规定一个线程只能调用一次,当同一个线程调用多次countDown()方法时,每次都会使计数器减一,
await()方法也并没有规定只能有一个线程执行该方法,如果多个线程同时执行await()方法,那么这几个线程都将处于等待状态,并且以共享模式享有同一个锁。

2、方法API 

方法说明
await()使当前线程进入同步队列进行等待,直到latch的值被减到0或者当前线程被中断,当前线程就会被唤醒。
await(long timeout, TimeUnit unit)等待timeout时间后,count的值还不是0,不再等待,那么将继续执行
countDown()使latch的值减1如果减到了0,则会唤醒所有等待在这个latch上的线程。
getCount()获得latch的数值。

3、使用

public class Test {public static void main(String[] args) throws InterruptedException {//当前执行的线程数量Integer poolNum = 10;long start = System.currentTimeMillis();//初始化线程运行的数量CountDownLatch countDownLatch = new CountDownLatch(poolNum);Map<Integer,Integer> map = new HashMap<>();for (int i = 1; i <= poolNum; i++) {//耗时Integer time = i*1000;ThreadPoolUtils.execute(()->{try {//假设逻辑执行的耗时Thread.sleep(time);map.put(time,time);} catch (InterruptedException e) {e.printStackTrace();}finally {countDownLatch.countDown();}});}// 4分45秒 countDownLatch.getCount()还不是,不再等待,那么将继续执行countDownLatch.await(4 * 60 + 45);System.out.println("总耗时:"+(System.currentTimeMillis()-start));for (Integer key: map.keySet()){//打印出来的key值是没有顺序的,因为竞争的CPU资源不一样System.out.println("map的key为:"+key+" map的值为:"+ map.get(key));}}
}

http://www.lryc.cn/news/340539.html

相关文章:

  • 高校心理教育辅导系统|基于Springboot的高校心理教育辅导系统设计与实现(源码+数据库+文档)
  • Rockchip Android13 Vold(三):App层
  • 数据结构——单链表(C语言版)
  • :app debug:armeabi-v7a failed to configure C/C++
  • 计算机网络——应用层(4)DHCP和套接字编程
  • TF-IDF演算法(Term Frequency - Inverse Document Frequency)最好懂筆記
  • 2024年4月最新版GPT
  • 机器学习——模型评价
  • ARP代理
  • 手写前端控制并发任务
  • 好用的Python开发工具合集
  • 近屿智能全新推出AI培训产品:AIGC大模型工程师与产品经理学习路径图
  • Vue 3中的反向代理 和如何在服务器配置反向代理
  • 【机器学习】贝叶斯算法在机器学习中的应用与实例分析
  • 回归预测 | Matlab实现SSA-GRNN麻雀算法优化广义回归神经网络多变量回归预测(含优化前后预测可视化)
  • SQL SERVER的安装
  • (十一)C++自制植物大战僵尸游戏客户端更新实现
  • 关于Qt主窗口的菜单部件
  • rabbitmq每小时自动重启
  • 【多线程】单例模式 | 饿汉模式 | 懒汉模式 | 指令重排序问题
  • 00_Qt概述以及如何创建一个QT新项目
  • git报错
  • 【R: mlr3:超参数调优】
  • 使用Pandas实现股票交易数据可视化
  • 蓝桥杯刷题-乌龟棋
  • 美国纽扣电池认证标准要求16 CFR 第 1700和ANSI C18.3M标准
  • 华硕ROG幻16笔记本电脑模式切换管理工具完美替代华硕奥创中心管理工具
  • 【ROS2笔记六】ROS2中自定义接口
  • 设计模式-代理模式(Proxy)
  • 中伟视界:智慧矿山智能化预警平台功能详解