详解Java中CountDownLatch的用法
更新时间：2023年05月17日 10:39:15 作者：tizzybepeacejoy
这篇文章主要为大家详细介绍了Java中CountDownLatch类的用法，本文通过一些简单的示例进行了简单介绍，感兴趣的小伙伴可以跟随小编一起了解一下
CountDownLatch使用场景
线程计数器 用于线程执行任务,计数 等待线程结束
用法一: 等待所有的事情都做完
//程序计数器
CountDownLatch countDownLatch = new CountDownLatch(10000);
//2个线程
ExecutorService executorService = Executors.newFixedThreadPool(2);
AtomicInteger count = new AtomicInteger(0);
for (int i = 0; i < 10000; i++) {
executorService.submit(() -> {
count.getAndIncrement();//自增
System.out.println(Thread.currentThread().getName() + " : " + count.get());
countDownLatch.countDown();
});
}
//线程池 等待10s
executorService.awaitTermination(10, TimeUnit.SECONDS);
//关闭线程 其实是将线程状态设置为中断标志 必须等待所有线程处理完任务,才能完全关闭
executorService.shutdown();
//必须等待两个线程执行完 会一直等待下去，当然也可以设置指定时间等待超时 await(timeout);
countDownLatch.await();
}始终是2个线程在做事情，等2个线程做完事情才会停止下来。
用法二：假设2个线程做事情,刚开始并行做事情,等一个执行完成之后,另一个才能执行(实际还是计数)
//程序计数器
CountDownLatch countDownLatch = new CountDownLatch(1);
Thread thread1 =new Thread(()->{
System.out.println(" ---------------- 1 准备 ---------------- ");
try {
countDownLatch.await();
System.out.println(" ---------------- 1 finsh ---------------- ");
} catch (InterruptedException e) {
e.printStackTrace();
}
});
thread1.start();
Thread thread2 = new Thread(() -> {
System.out.println(" ---------------- 2 准备 ---------------- ");
try {
Thread.sleep(1_000);
System.out.println(" ---------------- 异步做事情 ---------------- ");
} catch (InterruptedException e) {
e.printStackTrace();
}finally {
countDownLatch.countDown();
}
});
thread2.start();
//main 在等main 结束 死循环
Thread.currentThread().join();刚开始一起在准备状态，然后分开做事情
用法三：退出条件
中断一个线程 count 到0
//程序计数器
CountDownLatch countDownLatch = new CountDownLatch(1);
Thread thread = Thread.currentThread();
Thread thread1 = new Thread(() -> {
try {
Thread.sleep(10_000);
} catch (InterruptedException e) {
e.printStackTrace();
}
// 1 中断条件1
countDownLatch.countDown();
});
thread1.start();
countDownLatch.await();
System.out.println(" ----------------- ");
}等待时间中断
//程序计数器
CountDownLatch countDownLatch = new CountDownLatch(1);
Thread thread = Thread.currentThread();
Thread thread1 = new Thread(() -> {
try {
Thread.sleep(10_000);
} catch (InterruptedException e) {
e.printStackTrace();
}
});
thread1.start();
//2 中断条件3
countDownLatch.await(5, TimeUnit.SECONDS);
System.out.println(" ----------------- ");
}就中断条件而言: 当前还可以父线程中断
//程序计数器
Thread thread1 = new Thread(() -> {
try {
Thread.sleep(10_000);
} catch (InterruptedException e) {
e.printStackTrace();
}
// 中断条件3
thread.interrupt();
});
thread1.start();
System.out.println(" ----------------- ");用法四： 封装结束完后通知事件
封装结束完后通知事件 参考 CyclicBarrier 通知
public class CountDownLatchTest4 extends CountDownLatch {
private Runnable runnable;
public CountDownLatchTest4(int count, Runnable runnable) {
super(count);
this.runnable = runnable;
}
@Override
public void countDown() {
super.countDown();
if (super.getCount()==0){
runnable.run();
}
}
public static void main(String[] args) throws InterruptedException {
//程序计数器
CountDownLatchTest4 countDownLatch = new CountDownLatchTest4(1,()->{
System.out.println(" 计数结束 .... ");
});
Thread thread1 = new Thread(() -> {
try {
Thread.sleep(2_000);
countDownLatch.countDown();
System.out.println(" thread 1 do something ");
} catch (InterruptedException e) {
e.printStackTrace();
}
});
Thread thread2 = new Thread(() -> {
try {
Thread.sleep(1_000);
System.out.println(" thread 2 do something ");
countDownLatch.countDown();
} catch (InterruptedException e) {
e.printStackTrace();
}
});
thread1.start();
thread2.start();
countDownLatch.await();
System.out.println(" ----------------- main 结束 ----------------- ");
}
}可以看到运行结束，通知事件
自定义计数器
当然我们也可以实现自己的计数器
/**
* 自定义 CountDown 计数器
*/
public class CountDown {
//计数器
private int count = 0;
private final int total;
public CountDown(int total) {
this.total = total;
}
public void countDown() {
synchronized (this) {
this.count++;
//锁住 ++ 通知其他线程
this.notifyAll();
}
}
public void aWait() throws InterruptedException {
synchronized (this) {
while (total != count) {
//不等于 则 继续等待
this.wait();
}
}
}
}测试
CountDown countDown = new CountDown( 5);
System.out.println(" 准备多线程处理任务 ");
IntStream.rangeClosed(1, 5).forEach(x -> {
new Thread(() -> {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(" 线程开始 ----- " + Thread.currentThread().getName());
countDown.countDown();
}, x + "").start();
});
try {
countDown.aWait();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(" 准备多线程处理任务 结束 ");
System.out.println(" ---------------------- ");
System.out.println(" 结束 mian ---------- ");
}测试结果
最后
CountDownLatch 可以用来计数，可以测试任务是否执行结束
也可以用来停止一个线程，也可以用来线程运行结束完后通知事件，彼此工作的线程互相独立不关心。
到此这篇关于详解Java中CountDownLatch的用法的文章就介绍到这了,更多相关Java CountDownLatch内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家
相关文章
这篇文章主要给大家介绍了关于Java定时器@Scheduled注解的使用方法,在Java中使用@Scheduled注解可以方便地实现定时任务的功能,文中介绍的非常详细,需要的朋友可以参考下2023-07-07
这篇文章主要介绍了Java中List分片方式详细解析，文章围绕主题展开详细的内容介绍，具有一定的参考价值，需要的小伙伴可以参考一下2022-09-09
在解释JSONP之前,我们需要了解下”同源策略“,这对理解跨域有帮助。基于安全的原因,浏览器是存在同源策略机制的,同源策略阻止从一个源加载的文档或脚本获取或设置另一个源加载额文档的属性。说的简单点就是浏览器限制脚本只能和同协议、同域名、同端口的脚本进行交互。2016-04-04
Netty中ChannelPoolHandler调用处理程序详解
这篇文章主要介绍了Netty中ChannelPoolHandler调用处理程序详解,Netty 是基于 Java NIO 的异步事件驱动的网络应用框架,使用 Netty 可以快速开发网络应用,Netty 提供了高层次的抽象来简化 TCP 和 UDP 服务器的编程,但是你仍然可以使用底层的 API,需要的朋友可以参考下2023-11-11
这篇文章主要介绍了浅谈JackSon的几种用法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-01-01
这篇文章主要介绍了java 中RSA的方式实现非对称加密的实例的相关资料,这里提供实例帮助大家理解这部分知识，需要的朋友可以参考下2017-08-08
现在面试Java开发时，基本都会问到Java虚拟机的知识，根据职位不同问的内容深浅又有所区别。本文整理了10道面试中常问的Java虚拟机面试题，希望对正在面试的同学有所帮助2021-06-06
数组对于每一门编程语言来说都是重要的数据结构之一，当然不同语言对数组的实现及处理也不尽相同。Java 语言中提供的数组是用来存储固定大小的同类型元素2022-04-04
这篇文章主要介绍了Java常用工具类—泛型，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-03-03
这篇文章主要介绍了Java axios与spring前后端分离传参规范总结，文章围绕主题展开详细的内容介绍，具有一定的参考价值，需要的朋友可以参考一下2022-08-08
最新评论