Java并发编程 - CountDownLatch

同步工具类可以是任何一个对象，只要它根据其自身的状态来协调线程的控制流。阻塞队列可以作为同步工具类，其他类型的同步工具类还包括 信号量（Semaphore）、栅栏（CyclicBarrier）以及闭锁（Latch）。

本文重点介绍 CountDownLatch的用法与应用场景。

CountDownLatch

CountDownLatch 是一种灵活的闭锁实现，它可以使一个或多个线程等待一组事件发生。CountDownLatch包括一个计数器，该计数器被初始化为一个正整数，表示需要等待的事件数量。countDown方法递减计数器，表示有一个事件已经发生了，而await方法等待计数器达到零，这表示所有需要等待的事件都已经发生。

package com.bytebeats.concurrent.api;

import java.util.Random;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

/**
 * 任务计时
 *
 * @author Ricky Fung
 * @create 2017-04-24 23:01
 */
public class CountDownLatchDemo {

    public static void main(String[] args) throws InterruptedException {

        CountDownLatchDemo demo = new CountDownLatchDemo();
        long time = demo.timeTasks(5, new Runnable() {
            @Override
            public void run() {

                Random random = new Random();
                int time = random.nextInt(1000);
                try {
                    System.out.println("thread "+Thread.currentThread().getName()+ " sleep "+time);
                    TimeUnit.MILLISECONDS.sleep(time);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });

        System.out.println("耗时:"+time);
    }

    public long timeTasks(int threadNum, final Runnable task) throws InterruptedException {

        final CountDownLatch startGate = new CountDownLatch(1);   //开始
        final CountDownLatch endGate = new CountDownLatch(threadNum);   //结束

        for(int i=0; i<threadNum; i++){

            Thread thread = new Thread(){
                @Override
                public void run() {

                    try {
                        startGate.await();
                        System.out.println("thread "+Thread.currentThread().getName()+ " start");
                        try {
                            task.run();
                            System.out.println("thread "+Thread.currentThread().getName()+ " end");
                        } finally {
                            endGate.countDown();
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            };
            thread.start();
        }
        long start = System.nanoTime();
        startGate.countDown();

        endGate.await();

        long end = System.nanoTime();
        return end - start;
    }
}

CountDownLatch与CyclicBarrier的区别

CountDownLatch 可以使一个线程或者一组线程等待一组事件的发生，调用await和countDown方法。
CyclicBarrier能阻塞一组线程直到某个时间发生。它与CountDownLatch的区别在于：CountDownLatch用于等待事件，而CyclicBarrier用于等待其他线程。

另外，CyclicBarrier可以被重置，而CountDownLatch不可以。