1700451781
1700451782
7)主线程继续执行,打印出成绩平均值。
1700451783
1700451784
CountDownLatch的作用是控制一个计数器,每个线程在运行完毕后会执行countDown,表示自己运行结束,这对于多个子任务的计算特别有效,比如一个异步任务需要拆分成10个子任务执行,主任务必须要知道子任务是否完成,所有子任务完成后才能进行合并计算,从而保证了一个主任务的逻辑正确性。这和我们的实际工作非常类似,比如领导安排了一个大任务给我,我一个人不可能完成,于是我把该任务分解给10个人做,在10个人全部完成后,我把这10个结果组合起来返回给领导—这就是CountDownLatch的作用。
1700451785
1700451786
1700451787
1700451788
1700451790
编写高质量代码:改善Java程序的151个建议 建议131:CyclicBarrier让多线程齐步走
1700451791
1700451792
思考这样一个案例:两个工人从两端挖掘隧道,各自独立奋战,中间不沟通,如果两人在汇合点处碰头了,则表明隧道已经挖通。这描绘的也是在多线程编程中,两个线程独立运行,在没有线程间通信的情况下,如何解决两个线程汇集在同一原点的问题。Java提供了CyclicBarrier(关卡,也有翻译为栅栏)工具类来实现,代码如下:
1700451793
1700451794
static class Worker implements Runnable{
1700451795
1700451796
//关卡
1700451797
1700451798
private CyclicBarrier cb;
1700451799
1700451800
public Worker(CyclicBarrier_cb){
1700451801
1700451802
cb=_cb;
1700451803
1700451804
}
1700451805
1700451806
public void run(){
1700451807
1700451808
try{
1700451809
1700451810
Thread.sleep(new Random().nextInt(1000));
1700451811
1700451812
System.out.println(Thread.currentThread().getName()+”-到达汇合点”);
1700451813
1700451814
//到达汇合点
1700451815
1700451816
cb.await();
1700451817
1700451818
}catch(Exception e){
1700451819
1700451820
//异常处理
1700451821
1700451822
}
1700451823
1700451824
}
1700451825
1700451826
}
1700451827
1700451828
public static void main(String[]args)throws Exception{
1700451829
1700451830
//设置汇集数量,以及汇集完成后的任务
[
上一页 ]
[ :1.700451781e+09 ]
[
下一页 ]