[Java并发编程实战]闭锁CountDownLatch实现（含代码）

路漫漫其修远兮，吾将上下而求索。———屈原《离骚》

闭锁

闭锁（latch）是一种 Synchronizer,他可以延迟线程的进度直到线程到达终止状态。

一个闭锁工作起来就像一道大门：直到闭锁达到终点状态之前，门一直是关闭的，没有线程通过，在终点状态到来的时候，门开了，允许所有线程都通过。一旦闭锁到达了终点状态，他就不能够在改变状态了，所以它会永远保持敞开的状态。

闭锁的应用

确保一个计算不会执行，直到它需要的资源被初始化。
确保一个服务不会开始，直到它依赖的服务都已经开始。
等待直到活动的所有部分都为继续处理做好准备。比如王者荣耀需要等待所有玩家准备才能开始。

闭锁的实现

CountDownLatch 是一个灵活的闭锁实现，可以用于上述几种情况，允许一个或者多个线程等待一个事件集的发生。闭锁的状态包括一个计数器，初始为一个正数，表示要等待的事件数。countDown方法对于计数器做减数操作，表示一个事件已经发生了，而 await阻塞方法将阻塞当前线程直到计数器减到零。

CountDownLatch示例

下面举个例子，CountDownLatchTest 创建两个特闭锁对象。第一个是主线程用于判断所有线程启动完毕的闭锁，用于阻塞子线程执行直到所有线程都启动完毕。第二个是子线程执行完毕的闭锁，直到每个线程都执行完毕后，才统计总共运行了多少时间。

import java.util.concurrent.CountDownLatch;

public class CountDownLatchTest{
	
	private static CountDownLatch main_cdl = new CountDownLatch(1);//闭锁1
	private static CountDownLatch sub_cdl = new CountDownLatch(5);//闭锁2
	
	public static void main(String[] args) {
		//创建五个线程并启动
		for(int i = 0; i < 5; i++) {
			new Thread(new SubThread()).start();
		}
		
		long start = System.nanoTime();
		main_cdl.countDown();//打开闭锁，让五个线程继续执行
		try {
			sub_cdl.await();//阻塞闭锁，等待五个线程都执行完毕
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		long end = System.nanoTime();
		System.out.println(end - start);//五个线程总共执行了多长时间
	}
	//子线程
	static class SubThread implements Runnable{
		public SubThread() {}
		@Override
		public void run() {
			try {
				main_cdl.await();//阻塞，等待主线程启动所有子线程你
				System.out.println(Thread.currentThread().getName() + ":runing");
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally {
				sub_cdl.countDown();//子线程执行完毕，计数器减1
			}
		}
	}
}