「java.util.concurrent并发包」之 CountDownLatch

一 CountDownLatch是什么

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

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

二 CountDownLatch如何工作

CountDownLatch.java类中定义的构造函数：

public void CountDownLatch(int count) {...}

构造器中的计数值（count）实际上就是闭锁需要等待的线程数量。这个值只能被设置一次，而且CountDownLatch没有提供任何机制去重新设置这个计数值。

与CountDownLatch的第一次交互是主线程等待其他线程。主线程必须在启动其他线程后立即调用CountDownLatch.await()方法。这样主线程的操作就会在这个方法上阻塞，直到其他线程完成各自的任务。

其他N 个线程必须引用闭锁对象，因为他们需要通知CountDownLatch对象，他们已经完成了各自的任务。这种通知机制是通过 CountDownLatch.countDown()方法来完成的；每调用一次这个方法，在构造函数中初始化的count值就减1。所以当N个线程都调用了这个方法，count的值等于0，然后主线程就能通过await()方法，恢复执行自己的任务。

三在实时系统中的使用场景

实现最大的并行性：有时我们想同时启动多个线程，实现最大程度的并行性。例如，我们想测试一个单例类。如果我们创建一个初始计数为1的CountDownLatch，并让所有线程都在这个锁上等待，那么我们可以很轻松地完成测试。我们只需调用一次countDown()方法就可以让所有的等待线程同时恢复执行。
开始执行前等待n个线程完成各自任务：例如应用程序启动类要确保在处理用户请求前，所有N个外部系统已经启动和运行了。

四代码实例

描述: 在这个例子中，我们有一个应用调用主类，所有外部系统准备(数据，资源，网络准备等)结束后通知闭锁，主类一致在闭锁等待，直到所有外部准备完成。

抽象类定义: 抽象准备接口(抽象类)

「java.util.concurrent并发包」之 CountDownLatch

 1 public abstract class BasePreparer implements Runnable {
 2 
 3     private CountDownLatch countDownLatch;
 4 
 5     private String prepareName;
 6 
 7     private boolean prepareDone;
 8 
 9     public BasePreparer(String prepareName, CountDownLatch countDownLatch) {
10         this.countDownLatch = countDownLatch;
11         this.prepareName = prepareName;
12         this.prepareDone = false;
13     }
14 
15     protected abstract void prepare();
16 
17     @Override
18     public void run() {
19         try {
20             prepare();
21             prepareDone = true;
22         } catch (Exception e) {
23             prepareDone = false;
24         } finally {
25             if (countDownLatch != null) {
26                 countDownLatch.countDown();
27             }
28         }
29     }
30 
31     public String getPrepareName() {
32         return prepareName;
33     }
34 
35     public boolean isPrepareDone() {
36         return prepareDone;
37     }
38 }

抽象类

实现类1: 模拟数据准备(后面2，3类似，只是成员变量简单变化)

 1 public class DataPreparer extends BasePreparer {
 2 
 3     public DataPreparer(CountDownLatch countDownLatch) {
 4         super("data prepare", countDownLatch);
 5     }
 6 
 7     @Override
 8     protected void prepare() {
 9         System.out.println(this.getPrepareName() + "is doing");
10         try {
11             TimeUnit.SECONDS.sleep(1);
12         } catch (InterruptedException e) {
13             e.printStackTrace();
14         }
15         System.out.println(this.getPrepareName() + "is done");
16     }
17 }

实现类1

一 CountDownLatch是什么

二 CountDownLatch如何工作

三 在实时系统中的使用场景

四 代码实例

三在实时系统中的使用场景

四代码实例