闭锁（CountDownLatch）

jdk5.0在java.util.concurrent包中提供了CountDownLatch，它是一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。

闭锁可以延迟线程的进度直到其到达终止状态，闭锁可以用来确保某些活动直到其他活动都完成才继续执行：

1）确保某个计算在其需要的所有资源都被初始化之后才继续执行；

2）确保某个服务在其他依赖的所有其他服务都已经启动之后才启动；

3）等待直到某个操作所有参与者都准备就绪在继续执行。

CountDownLatch的用法：

 CountDownLatch提供了一个await方法，该方式用于等待前边countdownlatch所统计的线程完成后，才可以向下执行，否则一直等待。

package com.dx.juc.test;

import java.util.concurrent.CountDownLatch;

public class CoutDownLatchTest {
    public static void main(String[] args) {
        Long start=System.currentTimeMillis();
        
        // 线程数
        CountDownLatch countDownLatch=new CountDownLatch(5);
        MyCallable myCallable=new MyCallable(countDownLatch); 
            
        for (int i = 0; i < 5; i++) {
            new Thread(myCallable).start();
        }
        
        try {
            // 等待所有任務完成后，才進行下邊的任務。
            countDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        
        Long end=System.currentTimeMillis();
        System.out.println("耗时："+(end-start)+" ms");
    }    
}

class MyCallable implements Runnable {
    private CountDownLatch countDownLatch;

    public MyCallable(CountDownLatch countDownLatch) {
        this.countDownLatch = countDownLatch;
    }

    public void run() {
        try {
            int sum = 0;
            for (int i = 0; i <= 100; i++) {
                sum += i;
            }
            System.out.println(sum);
        } finally {
            countDownLatch.countDown();
        }
    }

}

CountDownLatch原理及注意事项

1）CountDownLatch初始化的开启计数个数必须要到达0时，才会跳出等待，这个是等待跳过的一个依赖；

2）如果该统计个数初始化的值，大于调用countDown()的次数，就会导致线程一直等待状态，如下图：图一；

3）它实现的原理，就是给CountDownLatch一个初始化统计数，在监控的线程内部操作完成时，调用countDown()函数，调用一次则初始化监控统计数递减1。当调用了CountDownLatch的实例的await函数时，实际上是一直监控是否初始化监控统计数到达0否，一旦到达0，则跳出等待。进行await等待，向下执行。

图一：