public class Solver {
    final int N;
    final float[][] data;
    final CyclicBarrier barrier;
    volatile boolean over = false;
    public Solver(float[][] matrix) throws InterruptedException {
        data = matrix;
        N = matrix.length;
        //每一輪循環(huán)都會(huì)執(zhí)行，并且需要run執(zhí)行完才會(huì)觸發(fā)下一輪開啟.
        Runnable barrierAction =
                new Runnable() {
                    @Override
                    public void run() {
                        System.out.println("Solver.run");
                        over = true;
                    }
                };
        //初始化CyclicBarrier
        barrier = new CyclicBarrier(N, barrierAction);
        List<Thread> threads = new ArrayList<>(N);
        for (int i = 0; i < N; i++) {
            Thread thread = new Thread(new Worker(i));
            threads.add(thread);
            thread.start();
        }
        // wait until done
        for (Thread thread : threads) {
            thread.join();
        }
    }
    //程序入口
    public static void main(String[] args) throws InterruptedException {
        float[][] matrix = {{1.2F}, {2.2F}};
        Solver solver = new Solver(matrix);
    }
    class Worker implements Runnable {
        int myRow;
        Worker(int row) {
            myRow = row;
        }
        @Override
        public void run() {
            while (!done()) {
                processRow(myRow);
                try {
                    barrier.await();
                } catch (InterruptedException | BrokenBarrierException ex) {
                    return;
                }
            }
        }
        private void processRow(int myRow) {
            System.out.println("Worker.processRow:" + myRow);
        }
        private boolean done() {
            return over;
        }
    }
}

 if (barrier.await() == 0) {
   // log the completion of this iteration
 }

CyclicBarrier(int parties, Runnable barrierAction) 
//添加線程在屏障達(dá)到時(shí)觸發(fā)！線程會(huì)阻塞下一輪開始直到該線程執(zhí)行完畢。

int getParties()  //獲取當(dāng)前設(shè)置的屏障數(shù)

int await()       //等待直到所有線程執(zhí)行await達(dá)到屏障數(shù)

int await(long timeout, TimeUnit unit)  //等待直到所有線程執(zhí)行await達(dá)到屏障數(shù)或者超過指定超時(shí)時(shí)間

boolean isBroken()   //查詢當(dāng)前屏障是否處于broken狀態(tài)

void reset()         //重置當(dāng)前屏障數(shù)到初始時(shí)數(shù)量

int getNumberWaiting() //查詢當(dāng)前等待未到達(dá)屏障值的線程數(shù)