java CyclicBarrier java多线程之CyclicBarrier如何使用
chuyouyinghe 人气:0想了解java多线程之CyclicBarrier怎样使用的相关内容吗,chuyouyinghe在本文为您仔细讲解java CyclicBarrier的相关知识和一些Code实例,欢迎阅读和指正,我们先划重点:java多线程之CyclicBarrier,java,CyclicBarrier的实例详解,java,CyclicBarrier,下面大家一起来学习吧。
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个已经到达,都到齐了,继续走啊
如有疑问请留言或者到本站社区交流讨论,感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
加载全部内容