java 多线程编程之CountDownLatch

CountDownLatch类位于java.util.concurrent包下，利用它可以实现类似计数器的功能。CountDownLatch的一个非常典型的应用场景是：有一个任务想要往下执行，但必须要等到其他的任务执行完毕后才可以继续往下执行。假如我们这个想要继续往下执行的任务调用一个CountDownLatch对象的await()方法，其他的任务执行完自己的任务后调用同一个CountDownLatch对象上的countDown()方法，这个调用await()方法的任务将一直阻塞等待，直到这个CountDownLatch对象的计数值减到0为止。

CountDownLatch类只提供了一个构造器：

public CountDownLatch(int count) {  };  //参数count为计数值
           

下面这3个方法是CountDownLatch类中最重要的方法：

public void await() throws InterruptedException { };   //调用await()方法的线程会被挂起，它会等待直到count值为0才继续执行
public boolean await(long timeout, TimeUnit unit) throws InterruptedException { };  //和await()类似，只不过等待一定的时间后count值还没变为0的话就会继续执行
public void countDown() { };  //将count值减1
           

CountDownLatch的用法示例：

//一个CountDouwnLatch实例是不能重复使用的，也就是说它是一次性的，锁一经被打开就不能再关闭使用了，如果想重复使用，请考虑使用CyclicBarrier。
public class CountDownLatchTest {
 // 模拟了100米赛跑，10名选手已经准备就绪，只等裁判一声令下。当所有人都到达终点时，比赛结束。
 public static void main(String[] args) throws InterruptedException {
     // 开始的倒数锁 
     final CountDownLatch begin = new CountDownLatch(1);  
     // 结束的倒数锁 
     final CountDownLatch end = new CountDownLatch(10);  
     // 十名选手 
     final ExecutorService exec = Executors.newFixedThreadPool(10);  
     for (int index = 0; index < 10; index++) {
         final int NO = index + 1;  
         Runnable run = new Runnable() {
             public void run() {  
                 try {  
                     // 如果当前计数为零，则此方法立即返回。
                     // 等待
                	 System.out.println("await before====="+NO);
                     begin.await();  
                     Thread.sleep((long) (Math.random() * 10000));  
                     System.out.println("No." + NO + " arrived");  
                 } catch (InterruptedException e) {  
                	 
                 } finally {  
                     // 每个选手到达终点时，end就减一
                     end.countDown();
                 }  
             }  
         };  
         exec.submit(run);
     }  
     System.out.println("Game Start");  
     // begin减一，开始游戏
     begin.countDown();  
     // 等待end变为0，即所有选手到达终点
     end.await();  
     System.out.println("Game Over");  
     exec.shutdown();  
 }
}