如何使用CountDownLatch同步java多線程
最近寫了一個并發(fā)冪等測試,用線程池加入多個線程,同時啟動,領導覺得這樣有一定的風險,要求更嚴格一點,把所有的線程加入池中,然后同時啟動。
本來有多種方法,因為我們需要從多個線程中獲取返回值,所以我們用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)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關文章
SpringBoot使用Caffeine實現(xiàn)內(nèi)存緩存示例詳解
caffeine提供了四種緩存策略:分別為手動加載、自動加載、異步手動加載、異步自動加載,這篇文章主要介紹了SpringBoot使用Caffeine實現(xiàn)內(nèi)存緩存,需要的朋友可以參考下2023-06-06SpringBoot實現(xiàn)在一個模塊中引入另一個模塊
這篇文章主要介紹了SpringBoot實現(xiàn)在一個模塊中引入另一個模塊的方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-10-10MyBatis注解開發(fā)之實現(xiàn)自定義映射關系和關聯(lián)查詢
本文主要詳細介紹了MyBatis注解開發(fā)中,實現(xiàn)自定義映射關系和關聯(lián)查詢,文中有詳細的代碼示例,對學習MyBatis有一定的參考價值,需要的朋友可以參考閱讀2023-04-04springboot項目訪問圖片的3種實現(xiàn)方法(親測可用)
本文主要介紹了springboot項目訪問圖片的3種實現(xiàn)方法,通過springboot項目訪問除項目根目錄之外的其它目錄的圖片,具有一定的參考價值,感興趣的可以了解一下2023-09-09