java多线程之CyclicBarrier的使用方法
public class CyclicBarrierTest {
public static void main(String[] args) {
ExecutorService service = Executors.newCachedThreadPool();
final CyclicBarrier cb = new CyclicBarrier(3);
for(int i=0;i<3;i++){
Runnable runnable = new Runnable(){
public void run(){
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 (Exception e) {
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个已经到达，都到齐了，继续走啊
如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
