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