java中CyclicBarrier简单入门使用

转：http://blog.csdn.net/u012516914/article/details/40666153

版权声明：本文为博主原创文章，未经博主允许不得转载。

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

CyclicBarrier 支持一个可选的

Runnable

命令，在一组线程中的最后一个线程到达之后（但在释放所有线程之前），该命令只在每个屏障点运行一次。若在继续所有参与线程之前更新共享状态，此屏障操作 很有用。 在Java
JDK中是这样解释的，在我们日常开发中常常需要一组线程结束之后，再接着进行，我们就需要考虑使用这个类了。

[java]
view plain
copy
print?





执行之后打印如下结果：  

执行之后打印如下结果：

[java]
view plain
copy
print?





线程 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 到达都到齐，走吧  

线程 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 到达都到齐，走吧

[java]
view plain
copy
print?





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