并发之CyclicBarrier

CyclicBarrier，谓之循环栅栏。和CountDownLatch非常相似，不同的是，CountDownLatch是等其他线程到达，本线程继续往下执行；CyclicBarrier是等其他线程一起到达，大家一起继续执行下面的任务。
它的API描述如下：

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

    /** 采用了ReentrantLock ，监听进入栅栏的线程*/
    private final ReentrantLock lock = new ReentrantLock();
    private final Condition trip = lock.newCondition();
    /** 线程数量 */
    private final int parties;
    /*栅栏损坏后的任务 */
    private final Runnable barrierCommand;
    /** 一批为一代*/
    private Generation generation = new Generation();

//parties个线程到达栅栏后，优先执行barrierAction
public CyclicBarrier(int parties, Runnable barrierAction) {
        if (parties <= 0) throw new IllegalArgumentException();
        this.parties = parties;
        this.count = parties;
        this.barrierCommand = barrierAction;
    }
    public CyclicBarrier(int parties) {
        this(parties, null);
    }

熟悉了CountDownLatch后，理解CyclicBarrier也很容易。我们举个简单的例子，去某个景点游览，一批次凑够20人以后才可以进去。代码示例如下：

public class CyclicBarrierTest {
    private static CyclicBarrier cyclicBarrier;

    static class Tour implements Runnable{
        public void run() {
            try {
                System.out.println(Thread.currentThread().getName()+"到达");
                cyclicBarrier.await();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args){
        cyclicBarrier = new CyclicBarrier(5, new Runnable() {
            @Override
            public void run() {
                //一代的线程都到达后，执行后面的任务
                System.out.println("够5个人了，进去游览了....");
            }
        });

        for(int i = 0 ; i < 20 ; i++){
            new Thread(new Tour(),"游客"+i).start();
        }
    }
}

结果如下：

结果

可以看到，一旦有5个人到达，就会打破栅栏，去游览了。而且，栅栏也确是可以循环利用的，一代一更新。