多线程之countDownLatch

淩亂°似流年 2024-03-31 16:36 97阅读 0赞

**1.****背景：**

*  countDownLatch是在java1.5被引入，跟它一起被引入的工具类还有CyclicBarrier、Semaphore、concurrentHashMap和BlockingQueue。
 *  存在于java.util.cucurrent包下。

**2.****概念**

*  countDownLatch这个类使一个线程等待其他线程各自执行完毕后再执行。
 *  是通过一个计数器来实现的，计数器的初始值是线程的数量。每当一个线程执行完毕后，计数器的值就-1，当计数器的值为0时，表示所有线程都执行完毕，然后在闭锁上等待的线程就可以恢复工作了。

**3.****源码**

*  countDownLatch类中只提供了一个构造器：

//参数count为计数值

public CountDownLatch(int count) \{ \};

类中有三个方法是最重要的：

//调用await()方法的线程会被挂起，它会等待直到count值为0才继续执行

public void await() throws InterruptedException \{ \};

//和await()类似，只不过等待一定的时间后count值还没变为0的话就会继续执行

public boolean await(long timeout, TimeUnit unit) throws InterruptedException \{ \};

//将count值减1

public void countDown() \{ \};

**4.****示例**

普通示例：

public class CountDownLatchTest \{

public static void main(String\[\] args) \{

final CountDownLatch latch = new CountDownLatch(2);

System.out.println("主线程开始执行…… ……");

//第一个子线程执行

ExecutorService es1 = Executors.newSingleThreadExecutor();

es1.execute(new Runnable() \{

@Override

public void run() \{

try \{

Thread.sleep(3000);

System.out.println("子线程："\+Thread.currentThread().getName()\+"执行");

\} catch (InterruptedException e) \{

e.printStackTrace();

\}

latch.countDown();

\}

\});

es1.shutdown();

//第二个子线程执行

ExecutorService es2 = Executors.newSingleThreadExecutor();

es2.execute(new Runnable() \{

@Override

public void run() \{

try \{

Thread.sleep(3000);

\} catch (InterruptedException e) \{

e.printStackTrace();

\}

System.out.println("子线程："\+Thread.currentThread().getName()\+"执行");

latch.countDown();

\}

\});

es2.shutdown();

System.out.println("等待两个线程执行完毕…… ……");

try \{

latch.await();

\} catch (InterruptedException e) \{

e.printStackTrace();

\}

System.out.println("两个子线程都执行完毕，继续执行主线程");

\}

\}

发表评论取消回复

表情：

评论列表（有 0 条评论，97人围观）

还没有评论，来说两句吧...

相关阅读

相关多线程之countDownLatch

1.背景： countDownLatch是在java1.5被引入，跟它一起被引入的工具类还有CyclicBarrier、Semaphore、concurrentHash

淩亂°似流年/ 2024年03月31日 16:36/ 0 赞/ 98 阅读

相关多线程 - CountDownLatch

CountDownLatch 的作用是在一个或多个线程等待其他线程完成执行某个操作后再继续执行。一般情况下，一个线程（或者多个线程）等待其他线程执行完某个操作之后再开

亦凉/ 2024年03月22日 03:22/ 0 赞/ 123 阅读

相关多线程同步器之CountDownLatch

文章目录 CountDownLatch是什么核心方法构造方法常用的其他三个方法

我不是女神ヾ/ 2022年11月05日 12:59/ 0 赞/ 258 阅读

相关 [多线程] 多线程工具之CountDownLatch

前言在Java中, 如何启动多个线程. 随后使某项任务分步执行. (TODO 此处可以来2个说明图和小故事.) -------------------- 使用J

心已赠人/ 2022年09月15日 11:44/ 0 赞/ 289 阅读

相关多线程－CountDownLatch

好文：　　http://www.cnblogs.com/yezhenhan/archive/2012/01/07/2315652.html　　 p

素颜马尾好姑娘i/ 2022年07月15日 00:19/ 0 赞/ 277 阅读

相关 Java多线程之CountDownLatch

CountDownLatch犹如倒计时计数器，调用CountDownLatch对象的countDown方法就将计数器减1，当计数器为0时，则所有等待者或单个等待者开始执行。

淡淡的烟草味﹌/ 2022年06月16日 08:53/ 0 赞/ 249 阅读

相关多线程之CountDownLatch详解（五）

上篇博客我们介绍了一下[重入锁ReentrantLock][ReentrantLock]，这篇博客我们详细的介绍CountDownLatch。文章目录

我会带着你远行/ 2022年06月11日 09:57/ 0 赞/ 254 阅读

相关 java多线程之CountDownLatch

CountDownLatch是一个同步工具类，用来协调多个线程之间的同步。其能够使一个线程在等待另外一些线程完成各自工作之后，再继续执行。使用一个计数器进行实

小鱼儿/ 2022年05月17日 13:23/ 0 赞/ 272 阅读

相关多线程之CountDownLatch和CyclicBarrier

一、倒计时CountDownLatch CountDownLatch是一个非常实用的多线程控制工具类，称之为“倒计时器”，它允许一个或多个线程一直等待，直到其他线程的操作

╰+攻爆jí腚メ/ 2022年05月14日 00:20/ 0 赞/ 339 阅读

相关多线程发令枪CountDownLatch

如果我们创建多个线程，希望他们在同一时刻启动，那么就会用到类似发令枪的功能，也就是countDownLatch它有两个重要的方法await()阻塞线程，countDown()每

亦凉/ 2021年12月05日 03:07/ 0 赞/ 481 阅读