如何使用CountDownLatch同步java多線程
最近寫了一個并發(fā)冪等測試,用線程池加入多個線程,同時啟動,領(lǐng)導覺得這樣有一定的風險,要求更嚴格一點,把所有的線程加入池中,然后同時啟動。
本來有多種方法,因為我們需要從多個線程中獲取返回值,所以我們用CountDownLatch來同步多線程。CyclicBarrier也是可以同步多線程的,但因為其無法獲取返回值,最后只能選擇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在中文中就是門栓的意思,這樣就很好理解了,當有門栓時,latch.await()的線程都在等待,只有當門栓的個數(shù)為0時那些線程才能同時釋放出來,所以能同步運行多線程。
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
SpringBoot使用Caffeine實現(xiàn)內(nèi)存緩存示例詳解
caffeine提供了四種緩存策略:分別為手動加載、自動加載、異步手動加載、異步自動加載,這篇文章主要介紹了SpringBoot使用Caffeine實現(xiàn)內(nèi)存緩存,需要的朋友可以參考下2023-06-06
SpringBoot實現(xiàn)在一個模塊中引入另一個模塊
這篇文章主要介紹了SpringBoot實現(xiàn)在一個模塊中引入另一個模塊的方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-10-10
MyBatis注解開發(fā)之實現(xiàn)自定義映射關(guān)系和關(guān)聯(lián)查詢
本文主要詳細介紹了MyBatis注解開發(fā)中,實現(xiàn)自定義映射關(guān)系和關(guān)聯(lián)查詢,文中有詳細的代碼示例,對學習MyBatis有一定的參考價值,需要的朋友可以參考閱讀2023-04-04
Java Lambda表達式的方法引用和構(gòu)造器引用實例分析
這篇文章主要介紹了Java Lambda表達式的方法引用和構(gòu)造器引用,結(jié)合實例形式分析了Lambda表達式的方法引用和構(gòu)造器引用相關(guān)原理、用法及操作注意事項,需要的朋友可以參考下2019-09-09
springboot項目訪問圖片的3種實現(xiàn)方法(親測可用)
本文主要介紹了springboot項目訪問圖片的3種實現(xiàn)方法,通過springboot項目訪問除項目根目錄之外的其它目錄的圖片,具有一定的參考價值,感興趣的可以了解一下2023-09-09

