最近在看ZK的源码,看到了有用到java.util.concurrent.CountDownLatch 这个类。总结一下用法:
CountDownLatch,一个同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。 主要方法 public CountDownLatch(int count); public void countDown(); public void await() throws InterruptedException 构造方法参数指定了计数的次数 countDown方法,当前线程调用此方法,则计数减1 awaint方法,调用此方法会一直阻塞当前线程,直到计时器的值为0
下面通过一个例子展示,程序会一直等待countDownLatch的值变成0,才会打印出:“工人们做完了。”。
package com.get.set;
import java.util.concurrent.CountDownLatch;
public class CountDownLatchDemo{
public static void main(String args[]){
CountDownLatch countDownLatch=new CountDownLatch(2);
Worker workA=new Worker("wjy", countDownLatch);
Worker workB=new Worker("yuanyuan", countDownLatch);
workA.start();
workB.start();
try {
countDownLatch.await();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("工人们做完了。");
}
static class Worker extends Thread{
private String name;
private CountDownLatch countDownLatch;
public Worker(String name,CountDownLatch countDownLatch){
this.name=name;
this.countDownLatch=countDownLatch;
}
@Override
public void run(){
System.out.println("Hello, I am "+name);
this.countDownLatch.countDown();
}
}
}
//运行结果:
Hello, I am wjy
Hello, I am yuanyuan
工人们做完了。
注意:如果我们把CountDownLatch的初始值设为3,那么在上面这个程序中永远都不会打印出“工人们做完了。”
因为,程序会一直等待countDownLatch的值变成0.但是countDownLatch的值永远不可能变成0了。
相关推荐
在网上找的一个CountDownLatch的学习demo,感觉很不错,就摘抄过来了
《java并发编程》中CountDownLatch和CyclicBarrier用法实例大全,几乎包含了所有重要的用法
主要为大家详细介绍了Java中CountDownLatch用法,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
递减锁存器CountDownLatch的使用以及注意事项!
CountDownLatch计数器闭锁是一个能阻塞主线程,让其他线程满足特定条件下主线程再继续执行的线程同步工具。 Latch闭锁的意思,是一种同步的工具类。类似于一扇门:在闭锁到达结束状态之前,这扇门一直是关闭着的,不...
利用 CountDownLatch 类实现线程同步,而不用回调机制。详见我的博文 http://blog.csdn.net/kroclin/article/details/37956949
目录 CountDownLatch是什么? CountDownLatch如何工作? 在实时系统中的应用场景 应用范例 常见的面试题 代码样例
文章目录1 原理简介2 具体使用方法2.1 demo1 — await不传入时间,保证当前线程的其他操作在最后执行2.2 demo2 — await传入时间t,当前线程等其他线程时间t后就运行其他操作2.3 发令枪 源码地址:...
CountDownLatch与thread.join()的区别
CountDownLatch Demo
NULL 博文链接:https://cpjsjxy.iteye.com/blog/2272451
并发编程之CountDownLatch
java并发编程中CountDownLatch和CyclicBarrier的使用借鉴.pdf
mybaits 多线程 实现数据批量插入 (运用CountDownLatch实现闭锁) 1、mybatis批处理 2、数据分批量查询 3、数据分批量插入
CountDownLatch的基本用法 2.1 创建CountDownLatch对象 2.2 await()方法 2.3 countDown()方法 实现多线程任务的同步 3.1 场景介绍 3.2 使用CountDownLatch实现同步 主线程等待多个线程完成 4.1 场景介绍 4.2 使用...
主要为大家详细介绍了CountDownLatch的使用说明,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
CountDownLatch是一个同步工具类,它通过一个计数器来实现的,初始值为线程的数量。每当一个线程完成了自己的任务,计数器的值就相应得减1。当计数器到达0时,表示所有的线程都已执行完毕,然后在等待的线程就可以恢复...
Java并发编程一CountDownLatch、CyclicBarrier、Semaphore初使用 CountDownLatch、CyclicBarrier、Semaphore这些线程协作工具类是基于AQS的,看完这篇博客后可以去看下面这篇博客,了解它们是如何实现的。 Java并发...
TestSemaphore、TestLock、TestCyclicBarrier、CountdownLatchTest、LRUCache 博文链接:https://uule.iteye.com/blog/1543958
主要介绍了Java线程并发工具类CountDownLatch原理及用法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下