//parties表示屏障攔截的線(xiàn)程數(shù)量，當(dāng)屏障撤銷(xiāo)時(shí)，先執(zhí)行barrierAction，然后在釋放所有線(xiàn)程
public CyclicBarrier(int parties, Runnable barrierAction)
//barrierAction默認(rèn)為null
public CyclicBarrier(int parties)
 
/*
 *當(dāng)前線(xiàn)程等待直到所有線(xiàn)程都調(diào)用了該屏障的await()方法
 *如果當(dāng)前線(xiàn)程不是將到達(dá)的最后一個(gè)線(xiàn)程，將會(huì)被阻塞。解除阻塞的情況有以下幾種
 *    1）最后一個(gè)線(xiàn)程調(diào)用await()
 *    2）當(dāng)前線(xiàn)程被中斷
    3）其他正在該CyclicBarrier上等待的線(xiàn)程被中斷
    4）其他正在該CyclicBarrier上等待的線(xiàn)程超時(shí)
    5）其他某個(gè)線(xiàn)程調(diào)用該CyclicBarrier的reset()方法
 *如果當(dāng)前線(xiàn)程在進(jìn)入此方法時(shí)已經(jīng)設(shè)置了該線(xiàn)程的中斷狀態(tài)或者在等待時(shí)被中斷，將拋出InterruptedException，并且清除當(dāng)前線(xiàn)程的已中斷狀態(tài)。
 *如果在線(xiàn)程處于等待狀態(tài)時(shí)barrier被reset()或者在調(diào)用await()時(shí) barrier 被損壞，將拋出 BrokenBarrierException 異常。
 *如果任何線(xiàn)程在等待時(shí)被中斷，則其他所有等待線(xiàn)程都將拋出 BrokenBarrierException 異常，并將 barrier 置于損壞狀態(tài)。 *如果當(dāng)前線(xiàn)程是最后一個(gè)將要到達(dá)的線(xiàn)程，并且構(gòu)造方法中提供了一個(gè)非空的屏障操作（barrierAction），那么在允許其他線(xiàn)程繼續(xù)運(yùn)行之前，當(dāng)前線(xiàn)程將運(yùn)行該操作。如果在執(zhí)行屏障操作過(guò)程中發(fā)生異常，則該異常將傳播到當(dāng)前線(xiàn)程中，并將 barrier 置于損壞狀態(tài)。
 *
 *返回值為當(dāng)前線(xiàn)程的索引，0表示當(dāng)前線(xiàn)程是最后一個(gè)到達(dá)的線(xiàn)程
 */
public int await() throws InterruptedException, BrokenBarrierException
//在await()的基礎(chǔ)上增加超時(shí)機(jī)制，如果超出指定的等待時(shí)間，則拋出 TimeoutException 異常。如果該時(shí)間小于等于零，則此方法根本不會(huì)等待。
public int await(long timeout, TimeUnit unit) throws InterruptedException, BrokenBarrierException, TimeoutException
 
//將屏障重置為其初始狀態(tài)。如果所有參與者目前都在屏障處等待，則它們將返回，同時(shí)拋出一個(gè)BrokenBarrierException。
public void reset()

class Solver {
    final int N;    //矩陣的行數(shù)
    final float[][] data;    //要處理的矩陣
    final CyclicBarrier barrier;    //循環(huán)屏障
 
    class Worker implements Runnable {
        int myRow;
        Worker(int row) { myRow = row; }
        public void run() {
            while (!done()) {
                processRow(myRow);    //處理指定一行數(shù)據(jù)
 
                try {
                    barrier.await();     //在屏障處等待直到
                } catch (InterruptedException ex) { 
                    return; 
                } catch (BrokenBarrierException ex) {
                    return; 
                }
            }
        }
    }
 
    public Solver(float[][] matrix) {
        data = matrix;
        N = matrix.length;
        //初始化CyclicBarrier
        barrier = new CyclicBarrier(N, new Runnable() {
                                           public void run() { 
                                             mergeRows(...); //合并行
                                           }
                                       });
        for (int i = 0; i < N; ++i) 
            new Thread(new Worker(i)).start();
 
        waitUntilDone();
    }
}