java使用CountDownLatch等待多线程全部执行完成
前言
CountDownLatch允许一个或多个线程等待其他线程完成操作。
应用场景
假如有一个列表的大量数据等待处理，最后全部处理完毕后返回处理结果。普通做法就是从头遍历，一个个顺序执行，这样单线程处理效率不高，我们希望使用多线程的方式处理，同时在主线程等待所有子线程处理完成。
CountDownLatch的构造函数接收一个int类型的参数作为计数器，如果你想等待N个点完成，这里就传入N。
当我们调用一次CountDownLatch的countDown方法时，N就会减1，CountDownLatch的await会阻塞当前线程，直到N变成零。由于countDown方法可以用在任何地方，所以这里说的N个点，可以是N个线程，也可以是1个线程里的N个执行步骤。用在多个线程时，你只需要把这个CountDownLatch的引用传递到线程里。
示例代码
publicstaticvoidmain(Stringargs[]){
//初始化计数
AtomicIntegercount=newAtomicInteger(0);
//创建10个线程
ExecutorServiceexecutorService=Executors.newFixedThreadPool(10);
//设置CountDownLatch为10
CountDownLatchcountDownLatch=newCountDownLatch(10);
for(inti=0;i<10;i++){
executorService.execute(()->{
//每个线程累加10000次
for(intj=0;j<10000;j++){
count.addAndGet(1);
}
//线程最后执行countDown
countDownLatch.countDown();
});
}
try{
//调用await方法等待
countDownLatch.await();
}catch(Exceptione){
e.printStackTrace();
}
System.out.println(count.toString());
}
最后的执行结果就是10*10000=100000，可见所有线程都处理完了。
扩展
CountDownLatch的await方法还支持超时时间的设置，当等待超时时间子线程还没执行完将不再等待继续执行主线程。
publicbooleanawait(longtimeout,TimeUnitunit)
熟练使用多线程处理，可以再处理大量重复性工作时发挥多线程处理的效率优势。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
热门推荐
10 送老师新春祝福语简短
11 友情祝福语简短小故事
12 过年祝福语闺蜜简短
13 小班小孩生日祝福语简短
14 感恩老婆礼物祝福语简短
15 中考家长祝福语简短励志
16 母亲祝福语简短微信
17 节日结束祝福语简短的
18 端午祝福语安康-简短优美