Java CountDownLatch应用
Java的concurrent包里面的CountDownLatch其实可以把它看作一个计数器,只不过这个计数器的操作是原子操作,同时只能有一个线程去操作这个计数器,也就是同时只能有一个线程去减这个计数器里面的值。
你可以向CountDownLatch对象设置一个初始的数字作为计数值,任何调用这个对象上的await()方法都会阻塞,直到这个计数器的计数值被其他的线程减为0为止。
CountDownLatch的一个非常典型的应用场景是:有一个任务想要往下执行,但必须要等到其他的任务执行完毕后才可以继续往下执行。假如我们这个想要继续往下执行的任务调用一个CountDownLatch对象的await()方法,其他的任务执行完自己的任务后调用同一个CountDownLatch对象上的countDown()方法,这个调用await()方法的任务将一直阻塞等待,直到这个CountDownLatch对象的计数值减到0为止。
举个例子,有三个工人在为老板干活,这个老板有一个习惯,就是当三个工人把一天的活都干完了的时候,他就来检查所有工人所干的活。记住这个条件:三个工人先全部干完活,老板才检查。所以在这里用Java代码设计两个类,Worker代表工人,Boss代表老板,具体的代码实现如下:
//工人类
class Worker implements Runnable { private CountDownLatch countDownLatch;
private String name; public Worker(CountDownLatch countDownLatch, String name) {
this.countDownLatch = countDownLatch;
this.name = name;
} @Override
public void run() {
this.work();
try {
TimeUnit.SECONDS.sleep(new Random().nextInt(10));
} catch (InterruptedException e) {
} finally {
this.countDownLatch.countDown(); //闭锁计数器减一
}
} private void work() {
System.out.println(this.name + "正在干活。");
} }
//老板类
class Boss implements Runnable { private CountDownLatch countDownLatch; public Boss(CountDownLatch countDownLatch) {
this.countDownLatch = countDownLatch;
} @Override
public void run() {
System.out.println("老板正在等待所有公认干完活....");
try {
this.countDownLatch.await();
} catch (InterruptedException e) {
}
System.out.println("工人们都干完活了,老板开始检查了!!!!!!!!!!!!!!");
}
}
/**
* 闭锁测试
* Created by gan on 2019/5/18 22:47.
*/
public class CountDownLatchDemo { public static void main(String[] args) {
ExecutorService executor = Executors.newCachedThreadPool();
CountDownLatch countDownLatch = new CountDownLatch(3); Boss b1 = new Boss(countDownLatch);
Worker w1 = new Worker(countDownLatch, "小王");
Worker w2 = new Worker(countDownLatch, "校长");
Worker w3 = new Worker(countDownLatch, "小李"); executor.execute(b1);
executor.execute(w1);
executor.execute(w2);
executor.execute(w3); executor.shutdown();
}
}
当你运行CountDownLatchDemo这个对象的时候,你会发现是等所有的工人都干完了活,老板才来检查,下面是我本地机器上运行的一次结果,可以肯定的每次运行的结果可能与下面不一样,但老板检查永远是在后面的。
同样还可以完成如下功能: "将一个大任务分解为几个小任务用多线程跑,最后统计完成时间" 功能,代码如下:
/**
* Created by gan on 2019/5/19 0:05.
*/
public class CountDownLatchDemo2 { public static void main(String[] args) throws InterruptedException {
final CountDownLatch countDownLatch = new CountDownLatch(10);
long start = System.currentTimeMillis(); for (int i = 0; i < 10; i++) {
int j = i;
new Thread(() -> {
try {
TimeUnit.SECONDS.sleep(1);
System.out.println(Thread.currentThread().getName() + "执行完毕....." + j);
} catch (InterruptedException e) {
} finally {
countDownLatch.countDown();
}
}).start();
} System.out.println("主线程等待子线程完成。。。。");
countDownLatch.await(); //主线程到此进入阻塞状态,等待 countDownLatch.countDown()减为0后才进入就绪->执行
System.out.println("所有线程执行完毕,一共耗时===================>" + (System.currentTimeMillis() - start)); }
}
运行结果如下:
参考文章: https://zapldy.iteye.com/blog/746458
最新文章
- Android数据加密之MD5加密
- mongo(五)副本集
- 解决Ubuntu 12.10中ZIP文件名乱码的方法
- 关于在Eclipse里面启动了服务,但是localhost:8080无法访问的问题:
- OOM-killer 线上设置 +vm +OOM机制
- java类加载器行为[笔记]
- EntityFramework连接SQLite
- Cocos2d-X使用CCAnimation创建动画
- django初探-创建简单的博客系统
- 未能加载文件或程序集“System.Web.Mvc, Version=5.2.4.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35”或它的某一个依赖项
- spring boot 框架设计步骤
- 贪心算法----区间覆盖问题(POJ2376)
- dbcontext实例创建问题
- Alpha冲刺(4/10)——2019.4.27
- ext中grid根据数据不同显示不同样式
- Open-Source performance testing tools(From other site)
- ldap集成confluence
- bzoj千题计划203:bzoj3994: [SDOI2015]约数个数和
- 大数据系列之并行计算引擎Spark介绍
- laravel 开启sql调试
热门文章
- PHP如何解决网站大流量与高并发的问题(三)
- 在Eclipse IDE进行Struts开发时提示错误:java.lang.ClassNotFoundException: org.apache.struts2.dispatcher.FilterDispatcher的解决办法
- GROUP_CONCAT 将mysql多条数据合并为一条
- excel自增编号
- Nutch、Scrapy、Lucene、Heritrix、Solr、Sphinx
- ToggleButton 和 Switch
- flutter Form表单
- LeetCode_226. Invert Binary Tree
- 最新CSS兼容方案
- xray写POC踩坑