如何使用CountDownLatch同步j(luò)ava多線程
更新時間：2020年08月06日 10:37:55 作者：志不堅者智不達(dá)
這篇文章主要介紹了如何使用CountDownLatch同步j(luò)ava多線程,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
最近寫了一個并發(fā)冪等測試，用線程池加入多個線程，同時啟動，領(lǐng)導(dǎo)覺得這樣有一定的風(fēng)險，要求更嚴(yán)格一點，把所有的線程加入池中，然后同時啟動。
本來有多種方法，因為我們需要從多個線程中獲取返回值，所以我們用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在中文中就是門栓的意思，這樣就很好理解了，當(dāng)有門栓時，latch.await()的線程都在等待，只有當(dāng)門栓的個數(shù)為0時那些線程才能同時釋放出來，所以能同步運行多線程。
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
關(guān)于Mybatis實體別名支持通配符掃描問題小結(jié)
MyBatis可以使用簡單的 XML 或注解來配置和映射原生信息，將接口和 Java 的 POJOs(Plain Old Java Objects,普通的 Java對象)映射成數(shù)據(jù)庫中的記錄，這篇文章主要介紹了Mybatis實體別名支持通配符掃描的問題,需要的朋友可以參考下2022-01-01
Spring事件監(jiān)聽機制之@EventListener實現(xiàn)方式詳解
這篇文章主要介紹了Spring事件監(jiān)聽機制之@EventListener實現(xiàn)方式詳解,ApplicationContext的refresh方法還是初始化了SimpleApplicationEventMulticaster,發(fā)送事件式還是先獲取ResolvableType類型,再獲取發(fā)送監(jiān)聽列表,需要的朋友可以參考下2023-12-12
springboot+vue實現(xiàn)阿里云oss大文件分片上傳的示例代碼
阿里云推出了直傳,本文主要介紹了springboot+vue實現(xiàn)阿里云oss大文件分片上傳的示例代碼,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-06-06
這篇文章主要介紹了Java IO流之Properties類的使用方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-08-08
這篇文章主要介紹了Java字符串在內(nèi)存中的存儲位置，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-05-05
Java解決線程的不安全問題之volatile關(guān)鍵字詳解
這篇文章主要介紹了Java解決線程的不安全問題之volatile關(guān)鍵字詳解,可見性指一個線程對共享變量值的修改,能夠及時地被其他線程看到,而 volatile 關(guān)鍵字就保證內(nèi)存的可見性,需要的朋友可以參考下2023-08-08
在本篇文章里小編給大家整理了關(guān)于springboot+vue部署按照及運行方法和實例內(nèi)容，需要的朋友們學(xué)習(xí)參考下。2020-01-01
這篇文章主要為大家詳細(xì)介紹了Java并發(fā)編程之阻塞隊列，什么是阻塞隊列？主要的阻塞隊列及其方法介紹，感興趣的小伙伴們可以參考一下2016-03-03
這篇文章主要介紹了Java-Jackson使用詳解,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-03-03
idea使用pagehelper實現(xiàn)后端分頁功能的步驟詳解
這篇文章主要介紹了idea使用pagehelper實現(xiàn)后端分頁功能的步驟，本文通過實例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-09-09