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