這篇文章主要介紹“如何使用CountDownLatch”，在日常操作中，相信很多人在如何使用CountDownLatch問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”如何使用CountDownLatch”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

讓客戶滿意是我們工作的目標，不斷超越客戶的期望值來自于我們對這個行業(yè)的熱愛。我們立志把好的技術(shù)通過有效、簡單的方式提供給客戶，將通過不懈努力成為客戶在信息化領(lǐng)域值得信任、有價值的長期合作伙伴，公司提供的服務(wù)項目有：域名與空間、雅安服務(wù)器托管、營銷軟件、網(wǎng)站建設(shè)、霍州網(wǎng)站維護、網(wǎng)站推廣。

“CountDownLatch”

想象一下這樣一個場景，當我們需要等待某些線程執(zhí)行完之后，再執(zhí)行主線程的代碼，要怎么實現(xiàn)?

可能有人會說，簡單，用 join() 方法等待線程執(zhí)行完成之后再執(zhí)行主線程就行了，實現(xiàn)代碼是這樣的：

// 創(chuàng)建線程1 Thread t1 = new Thread(new Runnable() {     @Override     public void run() {         // do something     } }); t1.start();  // 創(chuàng)建線程2 Thread t2 = new Thread(new Runnable() {     @Override     public void run() {         // do something     } }); t2.start();  // 等待線程 1和線程 2 執(zhí)行完 t1.join(); t2.join();

當然，如果使用的是 Thread 來執(zhí)行任務(wù)，那這種寫法也是可行的。然而真實的(編碼)環(huán)境中我們是不會使用 Thread  來執(zhí)行多任務(wù)的，而是會使用線程池來執(zhí)行多任務(wù)，這樣可以避免線程重復(fù)啟動和銷毀所帶來的性能開銷，實現(xiàn)代碼如下：

// 創(chuàng)建固定線程數(shù)的線程池 ExecutorService executorService = Executors.newFixedThreadPool(2); // 任務(wù)一 executorService.submit(new Runnable() {     @Override     public void run() {         // do something     } }); // 任務(wù)二 executorService.submit(new Runnable() {     @Override     public void run() {         // do something     } });

那么這時候問題來了，線程池是沒有 join() 方法的，那要怎么實現(xiàn)等待呢?

這個時候就要派出我方大將“CountDownLatch”啦。

吾有上將潘鳳，可斬華雄... 出場數(shù)秒，潘鳳...“卒”。

等等導(dǎo)演，我覺得劇情應(yīng)該是這樣的...

CountDownLatch使用

為了實現(xiàn)等待所有線程池執(zhí)行完之后再執(zhí)行主線程的邏輯，我決定使用  AQS(AbstractQueuedSynchronizer，抽象同步框架)下的著名類 CountDownLatch 來實現(xiàn)此功能，具體的實現(xiàn)代碼如下：

public static void main(String[] args) throws InterruptedException {     // 創(chuàng)建 CountDownLatch     CountDownLatch countDownLatch = new CountDownLatch(2);      // 創(chuàng)建固定線程數(shù)的線程池     ExecutorService executorService = Executors.newFixedThreadPool(2);     // 任務(wù)一     executorService.submit(new Runnable() {         @Override         public void run() {             // do something             try {                 // 讓此任務(wù)執(zhí)行 1.2s                 Thread.sleep(1200);             } catch (InterruptedException e) {                 e.printStackTrace();             }             System.out.println("我是任務(wù)一");             countDownLatch.countDown();         }     });     // 任務(wù)二     executorService.submit(new Runnable() {         @Override         public void run() {             // do something             try {                 // 讓此任務(wù)執(zhí)行 1.2s                 Thread.sleep(1000);             } catch (InterruptedException e) {                 e.printStackTrace();             }             System.out.println("我是任務(wù)二");             countDownLatch.countDown();         }     });          // 等待任務(wù)執(zhí)行完成     countDownLatch.await();     System.out.println("程序執(zhí)行完成~"); }

以上程序執(zhí)行結(jié)果如下：

從上述結(jié)果可以看出，主線程的執(zhí)行是等待任務(wù)一和任務(wù)二都執(zhí)行完成之后才執(zhí)行的。

CountDownLatch實現(xiàn)原理

CountDownLatch 中 count down 是倒數(shù)的意思，latch  則是門閂的含義。整體含義可以理解為倒數(shù)的門栓，似乎有點“321，芝麻開門”的感覺，CountDownLatch 的作用也正是如此。

CountDownLatch 在創(chuàng)建的時候需要傳入一個整數(shù)，在這個整數(shù)“倒數(shù)”到 0  之前，主線程需要一直掛起等待，直到其他的線程都執(zhí)行之后，主線才能繼續(xù)執(zhí)行。

CountDownLatch執(zhí)行流程

CountDownLatch 的實現(xiàn)是在其內(nèi)部創(chuàng)建并維護了一個 volatile 類型的整數(shù)計數(shù)器，當調(diào)用 countDown()  方法時，會嘗試將整數(shù)計數(shù)器 -1，當調(diào)用 wait() 方法時，當前線程就會判斷整數(shù)計數(shù)器是否為 0，如果為 0，則繼續(xù)往下執(zhí)行，如果不為  0，則使當前線程進入等待狀態(tài)，直到某個線程將計數(shù)器設(shè)置為 0，才會喚醒在 await() 方法中等待的線程繼續(xù)執(zhí)行。

CountDownLatch常用方法

// 線程被掛起直到 count 值為 0 才繼續(xù)執(zhí)行 public void await() throws InterruptedException { };     // 和 await() 類似，只不過等待一定的時間后 count 值還沒變?yōu)?nbsp;0 的話就會繼續(xù)執(zhí)行 public boolean await(long timeout, TimeUnit unit) throws InterruptedException { };    // 將 count 值減 1 public void countDown() { };

到此，關(guān)于“如何使用CountDownLatch”的學習就結(jié)束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續(xù)學習更多相關(guān)知識，請繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>

分享名稱：如何使用CountDownLatch
轉(zhuǎn)載來源：http://jinyejixie.com/article40/gpijeo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供做網(wǎng)站、網(wǎng)站建設(shè)、App開發(fā)、品牌網(wǎng)站建設(shè)、云服務(wù)器、面包屑導(dǎo)航

廣告

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