国内最全IT社区平台 联系我们 | 收藏本站
华晨云阿里云优惠2
您当前位置:首页 > 互联网 > java中CyclicBarrier简单入门使用

java中CyclicBarrier简单入门使用

来源:程序员人生   发布时间:2014-11-06 08:39:22 阅读次数:2965次

1个同步辅助类,它允许1组线程相互等待,直到到达某个公共屏障点 (common barrier point)。在触及1组固定大小的线程的程序中,这些线程必须不时地相互等待,此时 CyclicBarrier 很有用。由于该 barrier 在释放等待线程后可以重用,所以称它为循环 的 barrier。

CyclicBarrier 支持1个可选的 Runnable 命令,在1组线程中的最后1个线程到达以后(但在释放所有线程之前),该命令只在每一个屏障点运行1次。若在继续所有参与线程之前更新同享状态,此屏障操作 很有用。 在java JDK中是这样解释的,在我们平常开发中常常需要1组线程结束以后,再接着进行,我们就需要斟酌使用这个类了。

履行以后打印以下结果:
线程 pool⑴-thread⑴行将到达线程集合点1,已有  1 到达继续等候 线程 pool⑴-thread⑶行将到达线程集合点1,已有  2 到达继续等候 线程 pool⑴-thread⑵行将到达线程集合点1,已有  3 到达都到齐,走吧 线程 pool⑴-thread⑵行将到达线程集合点2,已有  1 到达继续等候 线程 pool⑴-thread⑴行将到达线程集合点2,已有  2 到达继续等候 线程 pool⑴-thread⑶行将到达线程集合点2,已有  3 到达都到齐,走吧 线程 pool⑴-thread⑶行将到达线程集合点3,已有  1 到达继续等候 线程 pool⑴-thread⑴行将到达线程集合点3,已有  2 到达继续等候 线程 pool⑴-thread⑵行将到达线程集合点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); } } }



生活不易,码农辛苦
如果您觉得本网站对您的学习有所帮助,可以手机扫描二维码进行捐赠
程序员人生
------分隔线----------------------------
分享到:
------分隔线----------------------------
关闭
程序员人生