/*CountDownLatch 闭锁*/
CountDownLatch 是一各同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待
闭锁可以延迟线程的进度 直到 其到达终止状态，闭锁可以用来 /*确保某些活动直到其他活动都完成才继续执行*/ ：
1.确保 某个计算 在其需要的所有资源都被初始化之后才继续执行；
2.确保 某个服务 在其依赖的所有其他服务都已经启动之后才启动；
3.等待 直到某个操作所有参与者都准备就绪再继续执行
/*
* CountDownLatch ：闭锁，在完成某些运算时，只有其他线程的运算全部完成，当前运算才继续执行
*
* CountDownLatch类是一个同步倒数计数器,构造时传入int参数,该参数就是计数器的初始值，每调用一次countDown()方法，计数器减1,
*
* 计数器大于0 时，await()方法会阻塞后面程序执行，直到计数器为0，await(long timeout, TimeUnit unit)，是等待一定时间，然后执行，不管计数器是否到0了。
* */
public class TestCountDownLatch {
public static void main(String[] args) {
//创建闭锁
CountDownLatch latch = new CountDownLatch(5); LatchThread lt = new LatchThread(latch); long startTime = System.currentTimeMillis(); for (int i = 0; i < 5; i++) {
new Thread(lt).start();
}
//让主线程进行等待，如果不使用闭锁，是无法得到 耗费的时间的，
//因为子线程 和 主线程是 并发的，所以需要让主线程等到 所有的子线程都执行完了，再去计算时间，才能得到结果
try {
latch.await(); // > 0?
} catch (InterruptedException e) { }
long endTime = System.currentTimeMillis();
System.out.println("耗费：" + (endTime - startTime) + "毫秒"); } } class LatchThread implements Runnable {
private CountDownLatch latch; public LatchThread(CountDownLatch latch) {
this.latch = latch;
} @Override
public void run() {
synchronized (this) {
try {
for (int i = 0; i < 50000; i++) {
if (i % 3 == 0) {
System.out.println(i);
}
}
} finally {
latch.countDown(); //-1
}
}
} }