1700451731
1700451732
ExecutorService es=Executors.newFixedThreadPool（num）；
1700451733
1700451734
//记录比赛成绩
1700451735
1700451736
List＜Future＜Integer＞＞futures=new ArrayList＜Future＜Integer＞＞（）；
1700451737
1700451738
//跑步者就位，所有线程处于等待状态
1700451739
1700451740
for（int i=0；i＜num；i++）{
1700451741
1700451742
futures.add（es.submit（new Runner（begin, end）））；
1700451743
1700451744
}
1700451745
1700451746
//发令枪响，跑步者开始跑步
1700451747
1700451748
begin.countDown（）；
1700451749
1700451750
//等待所有跑步者跑完全程
1700451751
1700451752
end.await（）；
1700451753
1700451754
int count=0；
1700451755
1700451756
//统计总分
1700451757
1700451758
for（Future＜Integer＞f：futures）{
1700451759
1700451760
count+=f.get（）；
1700451761
1700451762
}
1700451763
1700451764
System.out.println（“平均分数为：”+count/num）；
1700451765
1700451766
}
1700451767
1700451768
CountDownLatch类是一个倒数的同步计数器，在程序中启动了两个计数器：一个是开始计数器begin，表示的是发令枪；另外是结束计数器，一共有10个，表示的是每个线程的执行情况，也就是跑步者是否跑完比赛。程序执行逻辑如下：
1700451769
1700451770
1）10个线程都开始运行，执行到begin.await后线程阻塞，等待begin的计数变为0。
1700451771
1700451772
2）主线程调用begin的countDown方法，使begin的计数器为0。
1700451773
1700451774
3）10个线程继续运行。
1700451775
1700451776
4）主线程继续运行下一个语句，end的计数器不为0，主线程等待。
1700451777
1700451778
5）每个线程运行结束时把end的计数器减1，标志着本线程运行完毕。
1700451779
1700451780
6）10个线程全部结束，end计数器为0。
[
上一页 ]
[ :1.700451731e+09 ]
[
下一页 ]