代码语言：javascript复制
并发类CountDownLatch类的使用示例
* CountDownLatch = Count(计数) Down(减少) Latch(门闩(可以理解为控制开关))
* 该类是java.util.concurrent包(大神 Doug Lea)下的一个同步锁计数器类。
* 该类最有用的方法:
* (1)传入计数器初始值创建对象：CountDownLatch startLatch = new CountDownLatch(int cnt);
* (2)down()方法：对计数器进行减1操作，是同步方法。计数器原来大于0，只要减至0，则释放所有线程锁，使得线程继续工作；
* 计数器原来已经为0，则nothing to do.
* (3)await()方法：所有线程处于等待直至等待时间超时、或者期间线程发生中断.这里是一个跑步示例
JAVA代码：
代码语言：javascript复制package org.byron4j.quartz.concurr;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
/**
* @author Byron.Y.Y 2016年7月5日
* <pre>
* 并发类CountDownLatch类的使用示例
* CountDownLatch = Count(计数) Down(减少) Latch(门闩(可以理解为控制开关))
* 该类是java.util.concurrent包(大神 Doug Lea)下的一个同步锁计数器类。
* 该类最有用的方法:
* (1)传入计数器初始值创建对象：CountDownLatch startLatch = new CountDownLatch(int cnt);
* (2)down()方法：对计数器进行减1操作，是同步方法。计数器原来大于0，只要减至0，则释放所有线程锁，使得线程继续工作；
* 计数器原来已经为0，则nothing to do.
* (3)await()方法：所有线程处于等待直至等待时间超时、或者期间线程发生中断.
* </pre>
*
*/
public class CountDownLatch4Running{
private static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
public static void main(String[] args) throws Exception{
final CountDownLatch startLatch = new CountDownLatch(1);
final CountDownLatch endLatch = new CountDownLatch(10);
//创建线程池
final ExecutorService es = Executors.newFixedThreadPool(10);
//制定跑步规则--10个运动员（线程任务）
for( int i=1; i<=10; i ){
final int No = i;
Runnable runner = new Runnable() {
public void run() {
try {
//如果当前开始计数器为0立即返回。此处警示哨令未发出，所有运动员均处于预备状态（线程阻塞等待）
startLatch.await();
Thread.sleep((long)(Math.random() * 10000));//0-1的小数乘以10000到千级
System.out.println(No " 号运动员抵达终点." sdf.format(new Date()));
} catch (InterruptedException e) {
e.printStackTrace();
}finally{
//只要有运动员抵达终点，结束计数器减1
endLatch.countDown();
}
}
};
es.submit(runner);
/*Future future = es.submit(runner);
System.out.println(future.get());*/
}
//开始跑步...
startLatch.countDown();
System.out.println("预备，开始...");
//等待所有运动员抵达终点,或者15秒未抵达结束
endLatch.await(15000, TimeUnit.MILLISECONDS);
System.out.println("体育课跑步测试结束。");
//关闭线程池
es.shutdown();
}
}以下是运行结果：
代码语言：javascript复制<pre>
预备，开始...
4 号运动员抵达终点.2016-07-05 18:07:26
3 号运动员抵达终点.2016-07-05 18:07:26
6 号运动员抵达终点.2016-07-05 18:07:26
9 号运动员抵达终点.2016-07-05 18:07:27
2 号运动员抵达终点.2016-07-05 18:07:28
5 号运动员抵达终点.2016-07-05 18:07:28
10 号运动员抵达终点.2016-07-05 18:07:29
7 号运动员抵达终点.2016-07-05 18:07:30
1 号运动员抵达终点.2016-07-05 18:07:32
8 号运动员抵达终点.2016-07-05 18:07:33
体育课跑步测试结束。
</pre>
