导语

"路漫漫其修远兮，吾将上下而求索",最近在阅读鸿洋大神的博客时看到了java并发编程专题之闭锁CountDownLatch,自己也跟着写了写。最近发现刚学过的东西只要长时间不用就忘得一干二净，所以日常笔记予以记录，以便日后翻阅。
CountDownLatch是java中一个同步工具类，它允许一个或多个线程一直等待，直到其他线程的操作执行完后在执行。CountDownLatch在java1.5被引入，这个类能够使一个线程等待其他线程完成自己的工作后再执行，比如：应用程序的主线程希望子线程在完成框架的启动任务后再执行。

一. 基本原理

CountDownLatch是使用计数器来完成线程的等待，计数器的初始值为待完成的线程数。每当一个线程完成自己任务后，计数器就会减一，当计数器减为零时，表示所有线程已完成自己的任务，闭锁等待的线程就会恢复执行任务。

CountDownLatch基本原理图.png

二.使用示例

模拟场景：一家三口约定下班后去XXX饭店一起吃饭，但是他们上班的地点不同，远近也不同。所以先到饭店的需要等待其他家庭成员全部到齐后才一起开动。

• 1 抽象类Dinner实现了Runnable接口，重写run方法模拟到饭店的过程，定义抽象方法setSpeed()模拟到达饭店的时间。
• 2 Father、Mother、Son继承了Dinner类并重写了setSpeed方法。
• 3 主线程中初始化闭锁CountDownLatch、执行器Exetor、3个Dinner对象，并在3个线程执行后开始等待其他线程执行完毕。

Dinner.java

---

 public abstract class Dinner implements Runnable {
     private String name;
     private CountDownLatch mLatch;
     public Dinner(String name, CountDownLatch latch) {
        this.name = name;
        this.mLatch = latch;
        }

        @Override
        public void run() {
            setSpeed();
            System.out.println(getName() + "到达餐馆！");
            mLatch.countDown();
      }

        public String getName() {
            return this.name;
        }

        public abstract void setSpeed();
    }    

Father.java

---

public class father extends Dinner {

public father(String name, CountDownLatch latch) {
    super(name, latch);
}

@Override
public void setSpeed() {
    try {
        Thread.sleep(5000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}
}

其他的Mother.java 、Son.java也是继承了Dinner类，只是在SetSpeed中线程休眠的时间不同。

主线程Main
CountDownLatchTest.java

---

public class CountDownLatchTest {

public static void main(String[] args) {
    System.out.println("出发去餐馆...");
    CountDownLatch downLatch = new CountDownLatch(3);
    Executor executor = Executors.newFixedThreadPool(3);
    Dinner father = new father("father", downLatch);
    Dinner mother = new Mother("mother", downLatch);
    Dinner son = new Son("son", downLatch);
    executor.execute(son);
    executor.execute(mother);
    executor.execute(father);
    try {
        downLatch.await();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println("全部到达餐馆");
}
}

运行结果：

---

result.png

可以看到，当主线程执行await方法等待其他线程全部执行完毕。

三. 结束语

本文纯属个人经验及观点，如有错误欢迎指正、交流。☻