java.util.concurrent包探秘(一)之CyclicBarrier

1.  类介绍

    引用 自JDK1.6 API介绍：

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

  CyclicBarrier 支持一个可选的 Runnable 命令，在一组线程中的最后一个线程到达之后（但在释放所有线程之前），该命令只在每个屏障点运行一次。若在继续所有参与线程之前更新共享状态，此屏障操作 很有用。

 

2. 示例（参照网上资料）

    场景：每个线程代表一个跑步运动员，当所用运动员都准备好后，才一起出发，只要有一个人没有准备好，大家都等待。

package com.gw.concurrent;

import java.io.IOException;
import java.util.Random;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 *@author zcc
 *@date  2013-7-24
 *@description 
 *@version 1.0.0
 */
class Runner implements Runnable 
{  
  
    private CyclicBarrier barrier;  
    private String name;  
    final Random random = new Random();
    public Runner(CyclicBarrier barrier, String name) 
    {  
        super();  
        this.barrier = barrier;  
        this.name = name;  
    }  
    @Override  
    public void run() 
    {  
        try 
        {  
            Thread.sleep(1000 * random.nextInt(8));  
            System.out.println(name + " 准备就绪！");  
            barrier.await();  //在barrier中所有参与者调用wait方法之前，一直等待。
        } 
        catch (InterruptedException e) 
        {  
            e.printStackTrace();  
        } 
        catch (BrokenBarrierException e) 
        {  
            e.printStackTrace();  
        }   
    }  
}  
  
public class TestCyclicBarrier 
{  
  
    public static void main(String[] args) throws IOException, InterruptedException 
    {  
        CyclicBarrier barrier = new CyclicBarrier(3, new Runnable(){
			@Override
			public void run()
			{
				System.out.println("都到齐了，准备出发");
			}
		});  
  
        ExecutorService executor = Executors.newFixedThreadPool(3);  
        executor.submit(new Thread(new Runner(barrier, "zhangsan")));  
        executor.submit(new Thread(new Runner(barrier, "lisi")));  
        executor.submit(new Thread(new Runner(barrier, "wangwu")));  
  
        executor.shutdown();  
    }    
}