java中CyclicBarrier简单入门使用
2014-11-01 00:24
288 查看
一个同步辅助类,它允许一组线程互相等待,直到到达某个公共屏障点 (common barrier point)。在涉及一组固定大小的线程的程序中,这些线程必须不时地互相等待,此时 CyclicBarrier 很有用。因为该 barrier 在释放等待线程后可以重用,所以称它为循环 的 barrier。
CyclicBarrier 支持一个可选的
CyclicBarrier 支持一个可选的
Runnable命令,在一组线程中的最后一个线程到达之后(但在释放所有线程之前),该命令只在每个屏障点运行一次。若在继续所有参与线程之前更新共享状态,此屏障操作 很有用。 在java JDK中是这样解释的,在我们日常开发中常常需要一组线程结束之后,再接着进行,我们就需要考虑使用这个类了。
执行之后打印如下结果:
线程 pool-1-thread-1即将到达线程集合点1,已有 1 到达继续等候 线程 pool-1-thread-3即将到达线程集合点1,已有 2 到达继续等候 线程 pool-1-thread-2即将到达线程集合点1,已有 3 到达都到齐,走吧 线程 pool-1-thread-2即将到达线程集合点2,已有 1 到达继续等候 线程 pool-1-thread-1即将到达线程集合点2,已有 2 到达继续等候 线程 pool-1-thread-3即将到达线程集合点2,已有 3 到达都到齐,走吧 线程 pool-1-thread-3即将到达线程集合点3,已有 1 到达继续等候 线程 pool-1-thread-1即将到达线程集合点3,已有 2 到达继续等候 线程 pool-1-thread-2即将到达线程集合点3,已有 3 到达都到齐,走吧
<pre name="code" class="java">import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class CyclicBarrierTest { /** * @param args */ public static void main(String[] args) { ExecutorService ThreadPool = Executors.newCachedThreadPool(); final CyclicBarrier cyclic = new CyclicBarrier(3); for(int i=0;i<3;i++){ Runnable runnable = new Runnable() { @Override public void run() { try { Thread.sleep((long) (Math.random()*3000)); System.out.println("线程 " + Thread.currentThread().getName() + "即将到达线程集合点1,已有 " + (cyclic.getNumberWaiting()+1) + " 到达" + (cyclic.getNumberWaiting()==2 ? "都到齐,走吧": "继续等候")); cyclic.await(); Thread.sleep((long) (Math.random()*3000)); System.out.println("线程 " + Thread.currentThread().getName() + "即将到达线程集合点2,已有 " + (cyclic.getNumberWaiting()+1) + " 到达" + (cyclic.getNumberWaiting()==2 ? "都到齐,走吧": "继续等候")); cyclic.await(); Thread.sleep((long) (Math.random()*3000)); System.out.println("线程 " + Thread.currentThread().getName() + "即将到达线程集合点3,已有 " + (cyclic.getNumberWaiting()+1) + " 到达" + (cyclic.getNumberWaiting()==2 ? "都到齐,走吧": "继续等候")); cyclic.await(); } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } } }; ThreadPool.execute(runnable); } } }
相关文章推荐
- java中CyclicBarrier简单入门使用
- java并发编程之——CountDownLatch和CyclicBarrier的使用
- java并发编程中CountDownLatch和CyclicBarrier的使用 - [java]
- java CyclicBarrier使用
- Java CountDownLatch 和 CyclicBarrier 使用
- java多线程--同步屏障CyclicBarrier的使用
- Java-CyclicBarrier的简单例子
- Java Json API:Gson使用简单入门
- Java之CyclicBarrier使用
- 使用Java辅助类(CountDownLatch、CyclicBarrier、Semaphore)并发编程
- java.util.concurrent包(6)——CyclicBarrier使用
- java学习之旅27--键盘输入_Scanner类的使用_import简单入门
- 使用java并发工具栅栏(CyclicBarrier)实现多线程等待,同一时刻执行共同任务
- Java多线程--CyclicBarrier使用详解
- Java之CyclicBarrier使用
- Java线程知识__其他几种线程同步的工具类的使用(CyclicBarrier,CountDownLatch,Exchanger)
- java中CyclicBarrier的简单用法
- Java之CyclicBarrier使用
- [改善Java代码]使用CyclicBarrier让多线程齐步走
- 【java并发】线程同步工具CyclicBarrier的使用