Java线程总结(十一):并发包------CyclicBarrier
2016-09-14 00:04
686 查看
package com.ydj; import java.util.concurrent.CyclicBarrier; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class CyclicBarrierTest { /** * 表示大家彼此等待,大家集合好后才开始出发,分散活动后又在指定地点集合碰面。 * * 这就好比整个公司的人员利用周末时间集体郊游一样: * 先各自从家出发到公司集合后(没有集合则等待), 再同时出发到公园游玩, * 在指定地点集合后(没有集合则等待)再同时开始就餐 */ public static void main(String[] args) { ExecutorService service = Executors.newCachedThreadPool(); final CyclicBarrier cb = new CyclicBarrier(3);//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();//如果3个线程没有全部到达,就等待 Thread.sleep((long)(Math.random()*10000)); System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点2,当前已有" + (cb.getNumberWaiting()+1) + "个已经到达," + (cb.getNumberWaiting()==2?"都到齐了,继续走啊":"正在等候")); cb.await(); //如果3个线程没有全部到达,就等待 Thread.sleep((long)(Math.random()*10000)); System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点3,当前已有" + (cb.getNumberWaiting() + 1) + "个已经到达," + (cb.getNumberWaiting()==2?"都到齐了,继续走啊":"正在等候")); cb.await(); //如果3个线程没有全部到达,就等待 } catch (Exception e) { e.printStackTrace(); } } }; service.execute(runnable); } service.shutdown(); } }
运行结果:
相关文章推荐
- java高并发程序设计总结五:jdk并发包其他同步控制工具类:ReadWriteLock/CountDownLatch/CyclicBarrier/LockSupport
- Java线程(十):CyclicBarrier-用路障实现分阶段线程并发
- Java线程(CountDownLatch、CyclicBarrier、Semaphore)并发控制工具类
- Java并发编程之栅栏(CyclicBarrier)详解
- 【多线程_并发工具】 栅栏_CyclicBarrier
- Java_并发线程_Semaphore、CountDownLatch、CyclicBarrier、Exchanger
- 使用java并发工具栅栏(CyclicBarrier)实现多线程等待,同一时刻执行共同任务
- Java多线程与并发库高级应用之公共屏障点CyclicBarrier
- Java 并发同步器之CountDownLatch、CyclicBarrier
- Java并发学习笔记(四)-栅栏CyclicBarrier
- 并发编程中的CountDownLatch和CyclicBarrier
- Java并发工具类CyclicBarrier
- Synchronizer 闭锁(CountDownLatch,FutureTask ) 信号量(Semaphore) 关卡(CyclicBarrier) 知识点总结(java并发编程实践读书笔记三)
- Java 并发专题 : CyclicBarrier 打造一个安全的门禁系统
- java并发:CyclicBarrier的使用
- java 并发编程实战第三章同步辅助类CyclicBarrier解析
- java并发编程之——CountDownLatch和CyclicBarrier的使用
- 【Java并发编程】之二十二:并发新特性—障碍器CyclicBarrier(含代码)
- Java并发学习之十八——线程同步工具之CyclicBarrier
- Java并发之CountDownLatch、CyclicBarrier和Semaphore