java使用CountDownLatch等待多線程全部執(zhí)行完成
前言
CountDownLatch 允許一個(gè)或多個(gè)線程等待其他線程完成操作。
應(yī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方法可以用在任何地方，所以這里說的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，可見所有線程都處理完了。
擴(kuò)展
CountDownLatch的await方法還支持超時(shí)時(shí)間的設(shè)置，當(dāng)?shù)却瑫r(shí)時(shí)間子線程還沒執(zhí)行完將不再等待繼續(xù)執(zhí)行主線程。
public boolean await(long timeout, TimeUnit unit)
熟練使用多線程處理，可以再處理大量重復(fù)性工作時(shí)發(fā)揮多線程處理的效率優(yōu)勢。
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
如何在IDEA中對 hashCode()和 equals() 利用快捷鍵快速進(jìn)行方法重寫
這篇文章主要介紹了如何在IDEA中對 hashCode()和 equals() 利用快捷鍵快速進(jìn)行方法重寫,需要的朋友可以參考下2020-08-08
Java合并兩個(gè)List后并去掉重復(fù)項(xiàng)的兩種做法
工作中很多時(shí)候需要用到合并兩個(gè)List并去除其中的重復(fù)內(nèi)容,這是一個(gè)很簡單的操作,實(shí)現(xiàn)的方法也多種多樣,這篇文章主要給大家介紹了關(guān)于Java合并兩個(gè)List后并去掉重復(fù)項(xiàng)的兩種做法,需要的朋友可以參考下2023-10-10
本文主要介紹了Java中List分片的5種方法小結(jié)，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2021-11-11
JavaWeb連接數(shù)據(jù)庫MySQL的操作技巧
數(shù)據(jù)庫是編程中重要的一部分，它囊括了數(shù)據(jù)操作，數(shù)據(jù)持久化等各方面。在每一門編程語言中都占有相當(dāng)大的比例。本次，小編以MySQL為例，使用mvc編程思想，給大家講解下javaweb對數(shù)據(jù)庫的操作2017-02-02
springboot集成ftp實(shí)現(xiàn)文件上傳
這篇文章主要為大家詳細(xì)介紹了springboot集成ftp實(shí)現(xiàn)文件上傳，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2021-05-05
javax.validation包里@NotNull等注解的使用方式
這篇文章主要介紹了javax.validation包里@NotNull等注解的使用方式,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-01-01
SpringBoot自動(dòng)配置與啟動(dòng)流程詳細(xì)分析
這篇文章主要介紹了SpringBoot自動(dòng)配置原理分析，SpringBoot是我們經(jīng)常使用的框架，那么你能不能針對SpringBoot實(shí)現(xiàn)自動(dòng)配置做一個(gè)詳細(xì)的介紹。如果可以的話，能不能畫一下實(shí)現(xiàn)自動(dòng)配置的流程圖。牽扯到哪些關(guān)鍵類，以及哪些關(guān)鍵點(diǎn)2022-11-11
mybatis-plus mapper中foreach循環(huán)操作代碼詳解(新增或修改)
這篇文章主要介紹了mybatis-plus mapper中foreach循環(huán)操作代碼詳解(新增或修改),本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-11-11
Java簡易抽獎(jiǎng)系統(tǒng)小項(xiàng)目
這篇文章主要為大家詳細(xì)介紹了Java簡易抽獎(jiǎng)系統(tǒng)小項(xiàng)目，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2019-01-01
SpringBoot+Redis實(shí)現(xiàn)查找附近用戶的示例代碼
SpringDataRedis提供了十分簡單的地理位置定位的功能,本文主要介紹了SpringBoot+Redis實(shí)現(xiàn)查找附近用戶的示例代碼,具有一定的參考價(jià)值,感興趣的可以了解一下2024-02-02