最近寫了一個(gè)并發(fā)冪等測試，用線程池加入多個(gè)線程，同時(shí)啟動，領(lǐng)導(dǎo)覺得這樣有一定的風(fēng)險(xiǎn)，要求更嚴(yán)格一點(diǎn)，把所有的線程加入池中，然后同時(shí)啟動。

本來有多種方法，因?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>() {@Overridepublic 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)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。