java多线程之CyclicBarrier的使用方法
java多线程之CyclicBarrier的使用方法
publicclassCyclicBarrierTest{
publicstaticvoidmain(String[]args){
ExecutorServiceservice=Executors.newCachedThreadPool();
finalCyclicBarriercb=newCyclicBarrier(3);
for(inti=0;i<3;i++){
Runnablerunnable=newRunnable(){
publicvoidrun(){
try{
Thread.sleep((long)(Math.random()*10000));
System.out.println("线程"+Thread.currentThread().getName()+
"即将到达集合地点1，当前已有"+(cb.getNumberWaiting()+1)+"个已经到达，"+(cb.getNumberWaiting()==2?"都到齐了，继续走啊":"正在等候"));
cb.await();
Thread.sleep((long)(Math.random()*10000));
System.out.println("线程"+Thread.currentThread().getName()+
"即将到达集合地点2，当前已有"+(cb.getNumberWaiting()+1)+"个已经到达，"+(cb.getNumberWaiting()==2?"都到齐了，继续走啊":"正在等候"));
cb.await();
Thread.sleep((long)(Math.random()*10000));
System.out.println("线程"+Thread.currentThread().getName()+
"即将到达集合地点3，当前已有"+(cb.getNumberWaiting()+1)+"个已经到达，"+(cb.getNumberWaiting()==2?"都到齐了，继续走啊":"正在等候"));
cb.await();
}catch(Exceptione){
e.printStackTrace();
}
}
};
service.execute(runnable);
}
service.shutdown();
}
}
运行结果如下：
线程pool-1-thread-3即将到达集合地点1，当前已有1个已经到达，正在等候 线程pool-1-thread-1即将到达集合地点1，当前已有2个已经到达，正在等候 线程pool-1-thread-2即将到达集合地点1，当前已有3个已经到达，都到齐了，继续走啊 线程pool-1-thread-3即将到达集合地点2，当前已有1个已经到达，正在等候 线程pool-1-thread-1即将到达集合地点2，当前已有2个已经到达，正在等候 线程pool-1-thread-2即将到达集合地点2，当前已有3个已经到达，都到齐了，继续走啊 线程pool-1-thread-1即将到达集合地点3，当前已有1个已经到达，正在等候 线程pool-1-thread-3即将到达集合地点3，当前已有2个已经到达，正在等候 线程pool-1-thread-2即将到达集合地点3，当前已有3个已经到达，都到齐了，继续走啊
如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。