如何使用CountDownLatch同步j(luò)ava多線程
最近寫了一個(gè)并發(fā)冪等測(cè)試，用線程池加入多個(gè)線程，同時(shí)啟動(dòng)，領(lǐng)導(dǎo)覺得這樣有一定的風(fēng)險(xiǎn)，要求更嚴(yán)格一點(diǎn)，把所有的線程加入池中，然后同時(shí)啟動(dòng)。
本來有多種方法，因?yàn)槲覀冃枰獜亩鄠€(gè)線程中獲取返回值，所以我們用CountDownLatch來同步多線程。CyclicBarrier也是可以同步多線程的，但因?yàn)槠錈o法獲取返回值，最后只能選擇CountDownLatch.
因公司的代碼不便共享，這里只提供一小部分代碼。
CountDownLatch latch = new CountDownLatch(1);
<br data-filtered="filtered">ExecutorService pool;
if (concurrentNum != null&&concurrentNum <= maxConcurrentNum && concurrentNum > 0) {
pool = Executors.newFixedThreadPool(concurrentNum);
} else {
concurrentNum = defaultConcurrentNum;
pool = Executors.newFixedThreadPool(defaultConcurrentNum);
}
for (int i = 0; i < concurrentNum; i++) {
Future res = pool.submit(new Callable<Object>() {
@Override
public Object call() throws Exception {
latch.await();
Object retObj = executeApi();
return retObj;
}
});
resultList.add(res);
}
latch.countDown();
for (int i = 0; i < concurrentNum; i++) {
retList.add(resultList.get(i).get());
}
pool.shutdown();
這里順便提一下，latch在中文中就是門栓的意思，這樣就很好理解了，當(dāng)有門栓時(shí)，latch.await()的線程都在等待，只有當(dāng)門栓的個(gè)數(shù)為0時(shí)那些線程才能同時(shí)釋放出來，所以能同步運(yùn)行多線程。
以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
SpringBoot使用Caffeine實(shí)現(xiàn)內(nèi)存緩存示例詳解
caffeine提供了四種緩存策略:分別為手動(dòng)加載、自動(dòng)加載、異步手動(dòng)加載、異步自動(dòng)加載，這篇文章主要介紹了SpringBoot使用Caffeine實(shí)現(xiàn)內(nèi)存緩存,需要的朋友可以參考下2023-06-06
JavaWeb后臺(tái)購物車類實(shí)現(xiàn)代碼詳解
這篇文章主要介紹了JavaWeb后臺(tái)購物車類實(shí)現(xiàn)代碼詳解,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-07-07
java List刪除指定元素有四種方法,分別是普通for循環(huán),增強(qiáng)for循環(huán),CopyOnWriteArrayList以及原生的Iterator迭代器循環(huán)來刪除list中指定的某個(gè)元素,非常的簡單,并通過代碼示例講解的非常詳細(xì),需要的朋友可以參考下2024-04-04
SpringBoot實(shí)現(xiàn)在一個(gè)模塊中引入另一個(gè)模塊
這篇文章主要介紹了SpringBoot實(shí)現(xiàn)在一個(gè)模塊中引入另一個(gè)模塊的方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-10-10
這篇文章主要介紹了java中使用url進(jìn)行編碼和解碼，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-08-08
這篇文章主要介紹了聊一聊Java的JVM類加載機(jī)制,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04
MyBatis注解開發(fā)之實(shí)現(xiàn)自定義映射關(guān)系和關(guān)聯(lián)查詢
本文主要詳細(xì)介紹了MyBatis注解開發(fā)中，實(shí)現(xiàn)自定義映射關(guān)系和關(guān)聯(lián)查詢，文中有詳細(xì)的代碼示例，對(duì)學(xué)習(xí)MyBatis有一定的參考價(jià)值，需要的朋友可以參考閱讀2023-04-04
Java Lambda表達(dá)式的方法引用和構(gòu)造器引用實(shí)例分析
這篇文章主要介紹了Java Lambda表達(dá)式的方法引用和構(gòu)造器引用,結(jié)合實(shí)例形式分析了Lambda表達(dá)式的方法引用和構(gòu)造器引用相關(guān)原理、用法及操作注意事項(xiàng),需要的朋友可以參考下2019-09-09
這篇文章主要介紹了spring boot基于Java的容器配置講解，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-04-04
springboot項(xiàng)目訪問圖片的3種實(shí)現(xiàn)方法(親測(cè)可用)
本文主要介紹了springboot項(xiàng)目訪問圖片的3種實(shí)現(xiàn)方法,通過springboot項(xiàng)目訪問除項(xiàng)目根目錄之外的其它目錄的圖片,具有一定的參考價(jià)值,感興趣的可以了解一下2023-09-09