java使用CountDownLatch等待多線程全部執(zhí)行完成
前言
CountDownLatch 允許一個(gè)或多個(gè)線程等待其他線程完成操作。
應(yīng)用場(chǎng)景
假如有一個(gè)列表的大量數(shù)據(jù)等待處理，最后全部處理完畢后返回處理結(jié)果。普通做法就是從頭遍歷，一個(gè)個(gè)順序執(zhí)行，這樣單線程處理效率不高，我們希望使用多線程的方式處理，同時(shí)在主線程等待所有子線程處理完成。
CountDownLatch的構(gòu)造函數(shù)接收一個(gè)int類型的參數(shù)作為計(jì)數(shù)器，如果你想等待N個(gè)點(diǎn)完成，這里就傳入N。
當(dāng)我們調(diào)用一次CountDownLatch的countDown方法時(shí)，N就會(huì)減1，CountDownLatch的await會(huì)阻塞當(dāng)前線程，直到N變成零。由于countDown方法可以用在任何地方，所以這里說(shuō)的N個(gè)點(diǎn)，可以是N個(gè)線程，也可以是1個(gè)線程里的N個(gè)執(zhí)行步驟。用在多個(gè)線程時(shí)，你只需要把這個(gè)CountDownLatch的引用傳遞到線程里。
示例代碼
public static void main(String args[]){
//初始化計(jì)數(shù)
AtomicInteger count = new AtomicInteger(0);
//創(chuàng)建10個(gè)線程
ExecutorService executorService = Executors.newFixedThreadPool(10);
//設(shè)置CountDownLatch為10
CountDownLatch countDownLatch = new CountDownLatch(10);
for(int i=0;i<10;i++){
executorService.execute(() -> {
//每個(gè)線程累加10000次
for(int j=0;j<10000;j++){
count.addAndGet(1);
}
//線程最后執(zhí)行countDown
countDownLatch.countDown();
});
}
try{
//調(diào)用await方法等待
countDownLatch.await();
}catch(Exception e){
e.printStackTrace();
}
System.out.println(count.toString());
}
最后的執(zhí)行結(jié)果就是10*10000=100000，可見(jiàn)所有線程都處理完了。
擴(kuò)展
CountDownLatch的await方法還支持超時(shí)時(shí)間的設(shè)置，當(dāng)?shù)却瑫r(shí)時(shí)間子線程還沒(méi)執(zhí)行完將不再等待繼續(xù)執(zhí)行主線程。
public boolean await(long timeout, TimeUnit unit)
熟練使用多線程處理，可以再處理大量重復(fù)性工作時(shí)發(fā)揮多線程處理的效率優(yōu)勢(shì)。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
Java中的有限狀態(tài)機(jī)(設(shè)計(jì)模式——狀態(tài)模式)
這篇文章主要介紹了Java中的有限狀態(tài)機(jī)(設(shè)計(jì)模式——狀態(tài)模式),具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-08-08
Java實(shí)現(xiàn)samza轉(zhuǎn)換成flink
將Apache Samza作業(yè)遷移到Apache Flink作業(yè)是一個(gè)復(fù)雜的任務(wù),因?yàn)檫@兩個(gè)流處理框架有不同的API和架構(gòu),本文我們就來(lái)看看如何使用Java實(shí)現(xiàn)samza轉(zhuǎn)換成flink吧2024-11-11
這篇文章主要給大家介紹了關(guān)于java新人基礎(chǔ)入門之遞歸調(diào)用的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-02-02
java Spring Boot 配置redis pom文件操作
這篇文章主要介紹了java Spring Boot 配置redis pom文件操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-07-07
Java動(dòng)態(tài)代理和AOP應(yīng)用示例
這篇文章主要介紹了Java動(dòng)態(tài)代理和AOP應(yīng)用,結(jié)合實(shí)例形式分析了java動(dòng)態(tài)代理在AOP面向切面編程中的相關(guān)操作技巧與使用注意事項(xiàng),需要的朋友可以參考下2019-07-07
大家好，本篇文章主要講的是Java給PDF加水印并合并多個(gè)文件，感興趣的同學(xué)趕快來(lái)看一看吧，對(duì)你有幫助的話記得收藏一下2022-02-02
springboot整合騰訊云短信開(kāi)箱即用的示例代碼
這篇文章主要介紹了springboot整合騰訊云短信開(kāi)箱即用,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-03-03
springboot項(xiàng)目中jackson-序列化-處理 NULL教程
這篇文章主要介紹了springboot項(xiàng)目中jackson-序列化-處理 NULL教程，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-10-10
Java 代碼實(shí)例解析設(shè)計(jì)模式之監(jiān)聽(tīng)者模式
所謂監(jiān)聽(tīng)者模式，我理解的是構(gòu)建一個(gè)容器存放所有被監(jiān)聽(tīng)的線程或?qū)ο?，監(jiān)聽(tīng)每個(gè)線程或?qū)ο蟀l(fā)生的變化，若某個(gè)線程或?qū)ο笥|發(fā)指定規(guī)則，那么則對(duì)所有被監(jiān)聽(tīng)的線程或?qū)ο蟾鶕?jù)業(yè)務(wù)需要做處理2021-10-10
Redis高并發(fā)場(chǎng)景防止庫(kù)存數(shù)量超賣少賣
商品超賣是銷售數(shù)量超過(guò)實(shí)際庫(kù)存的情況,常因庫(kù)存管理不當(dāng)引發(fā),傳統(tǒng)庫(kù)存管理在高并發(fā)環(huán)境下易出錯(cuò),可通過(guò)線程加鎖或使用Redis同步庫(kù)存狀態(tài)解決,本文就來(lái)詳細(xì)的介紹一下,感興趣的可以了解一下2024-09-09