导语
"路漫漫其修远兮，吾将上下而求索",最近在阅读鸿洋大神的博客时看到了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方法等待其他线程全部执行完毕。
三. 结束语
本文纯属个人经验及观点，如有错误欢迎指正、交流。☻
