Java并发包之CountDownLatch

CountDownLatch是什么

注意: ==CountDownLatch不可重复使用，当计数器减少到0之后，就废了，无法继续使用了。==

CountDownLatch是在java1.5被引入的，跟它一起被引入的并发工具类还有CyclicBarrier、Semaphore、ConcurrentHashMap和BlockingQueue，它们都存在于java.util.concurrent包下。CountDownLatch这个类能够使一个线程等待其他线程完成各自的工作后再执行。例如，应用程序的主线程希望在负责启动框架服务的线程已经启动所有的框架服务之后再执行。

CountDownLatch是通过一个计数器来实现的，计数器的初始值为线程的数量。每当一个线程完成了自己的任务后，计数器的值就会减1。当计数器值到达0时，它表示所有的线程已经完成了任务，然后在闭锁上等待的线程就可以恢复执行任务。

我的理解

CountDownLatch 存在的意义

让主线程阻塞，等待线程结束后在运行

直译过来就是倒计数(CountDown)门闩(Latch)。倒计数不用说，门闩的意思顾名思义就是阻止前进。在这里就是指 CountDownLatch.await() 方法在倒计数为0之前会阻塞当前线程。

实现

CountDownLatch内部维护一个最大线程数，当每个线程执行结束，就调用 latch.countDown(); 将数量减 1 ,当数量为0的时候，就放弃阻塞主线程，也就是放弃 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); // 启动线程抓取 executors .execute(new GetRunnable(urisToGet[i], countDownLatch)); } countDownLatch.await();//主线程阻塞在这里，等到线程结束, //然后关闭线程池 executors.shutdown();