Java多线程之concurrent包(五)——CyclicBarrier
2016-03-03 14:41
399 查看
CyclicBarrier
当线程数达到了CyclicBarrier初始时规定的数目时,所有进入等待状态的线程被唤醒并继续。 后续线程进入,则计数器重新计数,一直循环。
CyclicBarrier就象它名字的意思一样,可看成是个障碍, 所有的线程必须到齐后才能一起通过这个障碍。
CyclicBarrier初始时还可带一个Runnable的参数, 此Runnable任务在CyclicBarrier的数目达到后,所有其它线程被唤醒前被执行。
如下代码:
运行结果如下:
当线程数达到了CyclicBarrier初始时规定的数目时,所有进入等待状态的线程被唤醒并继续。 后续线程进入,则计数器重新计数,一直循环。
CyclicBarrier就象它名字的意思一样,可看成是个障碍, 所有的线程必须到齐后才能一起通过这个障碍。
CyclicBarrier初始时还可带一个Runnable的参数, 此Runnable任务在CyclicBarrier的数目达到后,所有其它线程被唤醒前被执行。
如下代码:
public class TestCyclicBarrier { public static void main(String[] args) { ExecutorService exec = Executors.newCachedThreadPool(); final Random random=new Random(); final CyclicBarrier barrier=new CyclicBarrier(4,new Runnable(){ @Override public void run() { System.out.println("所有的进程数目都齐备了,准备一起做了!"); }}); for(int i=0;i<8;i++){ exec.execute(new Runnable(){ @Override public void run() { try { Thread.sleep(random.nextInt(1000)); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName()+"进入了"); try { barrier.await();//达到指定数目的barrier后,调用barrier中的run方法 } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } }}); } exec.shutdown(); } }
运行结果如下:
pool-1-thread-4进入了 pool-1-thread-7进入了 pool-1-thread-2进入了 pool-1-thread-1进入了 所有的进程数目都齐备了,准备一起做了! pool-1-thread-5进入了 pool-1-thread-8进入了 pool-1-thread-6进入了 pool-1-thread-3进入了 所有的进程数目都齐备了,准备一起做了!
相关文章推荐
- java对世界各个时区(TimeZone)的通用转换处理方法(转载)
- java-注解annotation
- java-模拟tomcat服务器
- java-用HttpURLConnection发送Http请求.
- java-WEB中的监听器Lisener
- Android IPC进程间通讯机制
- Android Native 绘图方法
- Android java 与 javascript互访(相互调用)的方法例子
- Python3写爬虫(四)多线程实现数据爬取
- 介绍一款信息管理系统的开源框架---jeecg
- 聚类算法之kmeans算法java版本
- java实现 PageRank算法
- PropertyChangeListener简单理解
- c++11 + SDL2 + ffmpeg +OpenAL + java = Android播放器
- 插入排序
- 冒泡排序
- 堆排序
- 快速排序