CountDownLatch使用

CountDownLatch可以应用于等待多个线程执行完毕后，再执行剩余逻辑，下面举例说明。

场景：程序启动后有三个初始化启动步骤，都是耗时操作，如果单线程顺序执行的话比较耗时，且各步骤的执行无关联，此时考虑多个线程同时进行初始化，但要保证程序业务逻辑的执行要在3个初始化完成之后，应用CountDownLatch可达到此效果，初始化CountDownLatch时构造函数传入3，每个线程执行完时CountDownLatch执行countDown方法，进行减1操作，这样当3个线程都执行完后，countDownLatch.await();后的代码才得以执行，达到效果（相当于在多线程环境下达到顺序执行的效果）。代码示例如下：

package current;import java.util.concurrent.CountDownLatch;public class CountDownLatchTest {public static void main(String[] args) {CountDownLatch countDownLatch = new CountDownLatch(3);// 线程1：进行程序启动的准备步骤1new Thread(new Runnable() {@Overridepublic void run() {try {Thread.sleep(5000);System.out.println("完成准备步骤1");countDownLatch.countDown();} catch (InterruptedException e) {e.printStackTrace();}}}).start();// 线程2：进行程序启动的准备步骤2new Thread(new Runnable() {@Overridepublic void run() {try {Thread.sleep(10000);System.out.println("完成准备步骤2");countDownLatch.countDown();} catch (InterruptedException e) {e.printStackTrace();}}}).start();// 线程3：进行程序启动的准备步骤3new Thread(new Runnable() {@Overridepublic void run() {try {Thread.sleep(5000);System.out.println("完成准备步骤3");countDownLatch.countDown();} catch (InterruptedException e) {e.printStackTrace();}}}).start();System.out.println("开始程序启动的准备步骤");try {countDownLatch.await();} catch (InterruptedException e) {e.printStackTrace();}System.out.println("步骤全部准备完毕，进行业务处理");}}

执行结果为：

开始程序启动的准备步骤
完成准备步骤1
完成准备步骤3
完成准备步骤2
步骤全部准备完毕，进行业务处理

CountDownLatch使用相关推荐

Java并发编程之CountDownLatch、CyclicBarrier和Semaphore
前言本文为对CountDownLatch.CyclicBarrier.Semaphore的整理使用 CountDownLatch CountDownLatch类位于java.util.concurr ...
java并发之同步辅助类CyclicBarrier和CountDownLatch
CyclicBarrier 的字面意思是可循环使用(Cyclic)的屏障(Barrier).它要做的事情是,让一组线程到达一个屏障(也可以叫同步点)时被阻塞,直到最后一个线程到达屏障时,屏障才会开门, ...
java 并发统计_java并发编程|CountDownLatch计数器
0x01,CountDownLatch介绍 CountDownLatch是一个计数器,作为java并发编程中三个组件之一,这个组件的使用频率还是很多的.这里分享下自己画的java并发编程组件的图,后面 ...
JAVA中的并发工具 -- CountDownLatch、CyclicBarrier、Semaphore
2019独角兽企业重金招聘Python工程师标准>>> CountDownLatch CountDownLatch允许一个或多个线程等待其他线程完成操作. CountDownLatc ...
Java常用多线程辅助工具---countdownLatch
为什么80%的码农都做不了架构师?>>> 前言上一篇博文说到semaphore,一个加强版的synchronized,该多线程辅助工具适用于控制对资源操作或者访问的场景.现在有一张 ...
一文搞懂 CountDownLatch 用法和源码！
点击上方蓝色"方志朋",选择"设为星标" 回复"666"获取独家整理的学习资料! CountDownLatch 是多线程控制的一种工具,它被 ...
CountDownLatch的实现分析
CountDownLatch CountdownLatch 是 JDK 并发包中提供的并发工具类,其允许一个或多个线程等待其他线程完成操作.常用作将一个任务拆分成多个子任务同时执行,只有子任务都执行完 ...
LeetCode 1195. Fizz Buzz Multithreaded--并发系列题目--Java 解法--AtomicInteger/CountDownLatch/CyclicBarrier
题目地址:Fizz Buzz Multithreaded - LeetCode Write a program that outputs the string representation of nu ...
CycliBarriar和CountdownLatch(计数器)
CyclicBarrier可以重复使用,而CountdownLatch不能重复使用. countDownLatch这个类使一个线程等待其他线程各自执行完毕再执行. 是通过一个计数器来实现的,计数器的初 ...
Redisson 分布式锁源码 11：Semaphore 和 CountDownLatch
前言 Redisson 除了提供了分布式锁之外,还额外提供了同步组件,Semaphore 和 CountDownLatch. Semaphore 意思就是在分布式场景下,只有 3 个凭证,也就意味着同 ...

CountDownLatch使用

CountDownLatch使用相关推荐

最新文章

热门文章