CyclicBarrier，謂之循環(huán)柵欄。和CountDownLatch非常相似，不同的是，CountDownLatch是等其他線程到達(dá)，本線程繼續(xù)往下執(zhí)行；CyclicBarrier是等其他線程一起到達(dá)，大家一起繼續(xù)執(zhí)行下面的任務(wù)。
它的API描述如下：

它允許一組線程互相等待，直到到達(dá)某個公共屏障點(diǎn) (common barrier point)。在涉及一組固定大小的線程的程序中，這些線程必須不時地互相等待，此時 CyclicBarrier 很有用。因?yàn)樵?barrier 在釋放等待線程后可以重用，所以稱它為循環(huán) 的 barrier。
構(gòu)造函數(shù)如下：

    /** 采用了ReentrantLock ，監(jiān)聽進(jìn)入柵欄的線程*/
    private final ReentrantLock lock = new ReentrantLock();
    private final Condition trip = lock.newCondition();
    /** 線程數(shù)量 */
    private final int parties;
    /*柵欄損壞后的任務(wù) */
    private final Runnable barrierCommand;
    /** 一批為一代*/
    private Generation generation = new Generation();

//parties個線程到達(dá)柵欄后，優(yōu)先執(zhí)行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也很容易。我們舉個簡單的例子，去某個景點(diǎn)游覽，一批次湊夠20人以后才可以進(jìn)去。代碼示例如下：

public class CyclicBarrierTest {
    private static CyclicBarrier cyclicBarrier;

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

    public static void main(String[] args){
        cyclicBarrier = new CyclicBarrier(5, new Runnable() {
            @Override
            public void run() {
                //一代的線程都到達(dá)后，執(zhí)行后面的任務(wù)
                System.out.println("夠5個人了，進(jìn)去游覽了....");
            }
        });

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

結(jié)果如下：

結(jié)果

可以看到，一旦有5個人到達(dá)，就會打破柵欄，去游覽了。而且，柵欄也確是可以循環(huán)利用的，一代一更新。