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