溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
前言
CountDownLatch 允許一個或多個線程等待其他線程完成操作。
應用場景
假如有一個列表的大量數據等待處理，最后全部處理完畢后返回處理結果。普通做法就是從頭遍歷，一個個順序執行，這樣單線程處理效率不高，我們希望使用多線程的方式處理，同時在主線程等待所有子線程處理完成。
CountDownLatch的構造函數接收一個int類型的參數作為計數器，如果你想等待N個點完成，這里就傳入N。
當我們調用一次CountDownLatch的countDown方法時，N就會減1，CountDownLatch的await會阻塞當前線程，直到N變成零。由于countDown方法可以用在任何地方，所以這里說的N個點，可以是N個線程，也可以是1個線程里的N個執行步驟。用在多個線程時，你只需要把這個CountDownLatch的引用傳遞到線程里。
示例代碼
public static void main(String args[]){
//初始化計數
AtomicInteger count = new AtomicInteger(0);
//創建10個線程
ExecutorService executorService = Executors.newFixedThreadPool(10);
//設置CountDownLatch為10
CountDownLatch countDownLatch = new CountDownLatch(10);
for(int i=0;i<10;i++){
executorService.execute(() -> {
//每個線程累加10000次
for(int j=0;j<10000;j++){
count.addAndGet(1);
}
//線程最后執行countDown
countDownLatch.countDown();
});
}
try{
//調用await方法等待
countDownLatch.await();
}catch(Exception e){
e.printStackTrace();
}
System.out.println(count.toString());
}
最后的執行結果就是10*10000=100000，可見所有線程都處理完了。
擴展
CountDownLatch的await方法還支持超時時間的設置，當等待超時時間子線程還沒執行完將不再等待繼續執行主線程。
public boolean await(long timeout, TimeUnit unit)
熟練使用多線程處理，可以再處理大量重復性工作時發揮多線程處理的效率優勢。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持億速云。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
