前言

創(chuàng)新互聯(lián)專業(yè)為企業(yè)提供寧遠(yuǎn)網(wǎng)站建設(shè)、寧遠(yuǎn)做網(wǎng)站、寧遠(yuǎn)網(wǎng)站設(shè)計(jì)、寧遠(yuǎn)網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計(jì)與制作、寧遠(yuǎn)企業(yè)網(wǎng)站模板建站服務(wù)，十多年寧遠(yuǎn)做網(wǎng)站經(jīng)驗(yàn)，不只是建網(wǎng)站，更提供有價值的思路和整體網(wǎng)絡(luò)服務(wù)。

CountDownLatch 允許一個或多個線程等待其他線程完成操作。

應(yīng)用場景

假如有一個列表的大量數(shù)據(jù)等待處理，最后全部處理完畢后返回處理結(jié)果。普通做法就是從頭遍歷，一個個順序執(zhí)行，這樣單線程處理效率不高，我們希望使用多線程的方式處理，同時在主線程等待所有子線程處理完成。

CountDownLatch的構(gòu)造函數(shù)接收一個int類型的參數(shù)作為計(jì)數(shù)器，如果你想等待N個點(diǎn)完成，這里就傳入N。
當(dāng)我們調(diào)用一次CountDownLatch的countDown方法時，N就會減1，CountDownLatch的await會阻塞當(dāng)前線程，直到N變成零。由于countDown方法可以用在任何地方，所以這里說的N個點(diǎn)，可以是N個線程，也可以是1個線程里的N個執(zhí)行步驟。用在多個線程時，你只需要把這個CountDownLatch的引用傳遞到線程里。

示例代碼

public static void main(String args[]){
  //初始化計(jì)數(shù)
  AtomicInteger count = new AtomicInteger(0);
  //創(chuàng)建10個線程
  ExecutorService executorService = Executors.newFixedThreadPool(10);
  //設(shè)置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);
    }
    //線程最后執(zhí)行countDown
    countDownLatch.countDown();
   });
  }
  try{
   //調(diào)用await方法等待
   countDownLatch.await();
  }catch(Exception e){
   e.printStackTrace();
  }
  System.out.println(count.toString());
 }

最后的執(zhí)行結(jié)果就是10*10000=100000，可見所有線程都處理完了。

擴(kuò)展

CountDownLatch的await方法還支持超時時間的設(shè)置，當(dāng)?shù)却瑫r時間子線程還沒執(zhí)行完將不再等待繼續(xù)執(zhí)行主線程。

public boolean await(long timeout, TimeUnit unit)

熟練使用多線程處理，可以再處理大量重復(fù)性工作時發(fā)揮多線程處理的效率優(yōu)勢。

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持創(chuàng)新互聯(lián)。

本文標(biāo)題：java使用CountDownLatch等待多線程全部執(zhí)行完成
網(wǎng)站URL：http://chinadenli.net/article44/gisjhe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站導(dǎo)航、網(wǎng)站制作、微信小程序、面包屑導(dǎo)航、營銷型網(wǎng)站建設(shè)、App設(shè)計(jì)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)