CountDownLatch是什么

CountDownLatch是在java1.5被引入的，跟它一起被引入的并發(fā)工具類還有CyclicBarrier、Semaphore、ConcurrentHashMap和BlockingQueue，它們都存在于java.util.concurrent包下。CountDownLatch這個(gè)類能夠使一個(gè)線程等待其他線程完成各自的工作后再執(zhí)行。例如，應(yīng)用程序的主線程希望在負(fù)責(zé)啟動(dòng)框架服務(wù)的線程已經(jīng)啟動(dòng)所有的框架服務(wù)之后再執(zhí)行。

CountDownLatch是通過一個(gè)計(jì)數(shù)器來實(shí)現(xiàn)的，計(jì)數(shù)器的初始值為線程的數(shù)量。每當(dāng)一個(gè)線程完成了自己的任務(wù)后，計(jì)數(shù)器的值就會(huì)減1。當(dāng)計(jì)數(shù)器值到達(dá)0時(shí)，它表示所有的線程已經(jīng)完成了任務(wù)，然后在閉鎖上等待的線程就可以恢復(fù)執(zhí)行任務(wù)。

我的理解

CountDownLatch 存在的意義

讓主線程阻塞，等待線程結(jié)束后在運(yùn)行

直譯過來就是倒計(jì)數(shù)(CountDown)門閂(Latch)。倒計(jì)數(shù)不用說，門閂的意思顧名思義就是阻止前進(jìn)。在這里就是指 CountDownLatch.await() 方法在倒計(jì)數(shù)為0之前會(huì)阻塞當(dāng)前線程。

實(shí)現(xiàn)

CountDownLatch內(nèi)部維護(hù)一個(gè)最大線程數(shù)，當(dāng)每個(gè)線程執(zhí)行結(jié)束，就調(diào)用
latch.countDown(); 將數(shù)量減 1 ,當(dāng)數(shù)量為0的時(shí)候，就放棄阻塞主線程，也就是放棄 countDownLatch.await()阻塞的線程

代碼解釋

 ExecutorService executors = Executors.newFixedThreadPool(pagecount);
    CountDownLatch countDownLatch = new CountDownLatch(pagecount);
    for (int i = 0; i < pagecount; i++) {
        HttpGet httpget = new HttpGet(urisToGet[i]);
        config(httpget);
         // 啟動(dòng)線程抓取
         executors
             .execute(new GetRunnable(urisToGet[i], countDownLatch));
            }
        countDownLatch.await();//主線程阻塞在這里，等到線程結(jié)束,
       //然后關(guān)閉線程池
       executors.shutdown();