多线程的同步器之倒计时门栓（CountDownLatch）的使用

CountDownLatch，一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。如线程A需要等待线程B执行完成（线程A和B可以视为单线程或者多个线程），线程A才能执行。

主要方法

 public CountDownLatch(int count);

 public void countDown();

 public void await() throws InterruptedException

 

构造方法参数指定了计数的次数

countDown方法，当前线程调用此方法，则计数减一

awaint方法，调用此方法会一直阻塞当前线程，直到计时器的值为0
http://blog.csdn.net/zx2612/article/details/53192666
使用场景：第一种：
第一个是一个开始信号，防止任何工人进行，直到司机准备他们继续进行；
第二个是一个完成信号，允许司机等待，直到所有的工人已经完成。 

第二种：

另一个典型的用法是将一个问题分成n份，与运行，执行部分和计数下降对锁描述每个部分，和队列的runnable对象给执行者。当所有的子部件都完成后，协调线程将能够通过等待。（当线程必须反复倒在这条路上，而不是使用

CyclicBarrier

。）

例如：

class Driver2 { // ...
void main() throws InterruptedException {
CountDownLatch doneSignal = new CountDownLatch(N);
Executor e = ...

for (int i = 0; i < N; ++i) // create and start threads
e.execute(new WorkerRunnable(doneSignal, i));

doneSignal.await();           // wait for all to finish
}
}

class WorkerRunnable implements Runnable {
private final CountDownLatch doneSignal;
private final int i;
WorkerRunnable(CountDownLatch doneSignal, int i) {
this.doneSignal = doneSignal;
this.i = i;
}
public void run() {
try {
doWork(i);
doneSignal.countDown();
} catch (InterruptedException ex) {} // return;
}

void doWork() { ... }
}

public class CountDownLatchDemo1 {

final static SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

public static void main(String[] args) throws InterruptedException {
//模拟两个工人
CountDownLatch latch = new CountDownLatch(2);
Worker worker1 = new Worker("张三",5000,latch);
Worker worker2 = new Worker("李四", 8000, latch);
worker1.start();
worker2.start();
latch.await();//等待所有的工人完成工作才继续执行
System.out.println("all work done at "+sdf.format(new Date()));  
}

static class Worker extends Thread{
private String name;
private int workTime;
private CountDownLatch downLatch;
public Worker(String name,int i,CountDownLatch latch) {
// TODO Auto-generated constructor stub
this.name = name;
this.workTime=i;
this.downLatch = latch;
}
@Override
public void run() {
try {
// TODO Auto-generated method stub
System.out.println("Worker " + name + " do work begin at "
+ sdf.format(new Date()));
doWork();//工作了
System.out.println("Worker " + name + " do work complete at "
+ sdf.format(new Date()));
} catch (Exception e) {
// TODO: handle exception
}finally{
downLatch.countDown();//工人工作完成，计数减去1
}

}
private void doWork() {
// TODO Auto-generated method stub
try {  

                Thread.sleep(workTime);  

            } catch (InterruptedException e) {  

                e.printStackTrace();  

            }  
}

}

}