java中CyclicBarrier简单入门使用

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

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);
         }
         
	}

}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

扫码关注云+社区

领取腾讯云代金券