在java5.0之后jdk引入了并发包，其中提供了四种同步器来辅助线程之间的交互，CountDownLatch是其中一个，引用JDK文档中的说法就是“一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。用给定的计数初始化 CountDownLatch。由于调用了 countDown() 方法，所以在当前计数到达零之前，await 方法会一直受阻塞。之后，会释放所有等待的线程，await 的所有后续调用都将立即返回。这种现象只出现一次——计数无法被重置。 ”
可以举这么一个例子，
•场景：多个队员赛跑一样，在开始的时候，裁判一声枪响，队员才能在同一个时间开始跑，但是每个队员到达终点的时间肯定是不一样的，而比赛必须在最后一个队员到达后才算结束，那么先到终点的队员就必须等待，直到最后一个队员到达，才能做下一步的事情，例如举行颁奖仪式。
package com.test.concurrent.countDownLatch;
import java.util.concurrent.CountDownLatch;
public class CountDownLatchDemo {
public static int count = 10;//10个选手
public static CountDownLatch latch = new CountDownLatch(count);
public static void play() {
latch = new CountDownLatch(count);
for (int i = 1; i <= count; i++) {
new Thread(new Runner(i,latch)).start();
}
try {
latch.await();//阻塞处，都得等着所有人到达终点
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("都跑到头了吧，开始颁奖。。。。啦啦啦。。。。");
}
public static void main(String[] args) {
play();
}
}
Runner类如下：
package com.test.concurrent.countDownLatch;
import java.util.concurrent.CountDownLatch;
import com.test.util.SleepUtil;
public class Runner implements Runnable {
private int index;
private CountDownLatch latch;
public Runner(int index, CountDownLatch latch) {
this.index = index;
this.latch = latch;
}
public void run() {
SleepUtil.sleep(1000);//可以改为随机数
System.out.println(">>>>"+index + "号选手跑到终点！");
latch.countDown();
}
}
这个Demo可以运行，结果类似如下：
>>>>2号选手跑到终点！ >>>>6号选手跑到终点！ >>>>8号选手跑到终点！ >>>>10号选手跑到终点！ >>>>3号选手跑到终点！ >>>>1号选手跑到终点！ >>>>4号选手跑到终点！ >>>>5号选手跑到终点！ >>>>7号选手跑到终点！ >>>>9号选手跑到终点！ 都跑到头了吧，开始颁奖。。。。啦啦啦。。。。
准备下一篇文章说一下CyclicBarrier ^_^