協調線程間同步的類之二------CyclicBarrier 學習筆記

一。

         1>CyclicBarrier相似於CountDownLatch也是個計數器，不一樣的是CyclicBarrier數的是調用了CyclicBarrier.await()進入等待的線程數，當線程達到了CyclicBarrier初始時規定的數目時，全部進入等待狀態的線程被喚醒並繼續。而CountDownLatch的做用是 只有線程中CountDownLatch被數到0時，才執行CountDownLatch對象await操做後面的邏輯功能。  想探究CountDownLatch能夠參考上篇博文     

        2>CyclicBarrier就像他的名字同樣，能夠當作是個障礙，全部的線程必須到期後才能一塊兒經過這個障礙

         3>CyclicBarrier初始時還能夠帶一個Runnable參數，此Runnable任務在CyclicBarrier的數目達到後、全部其餘線程被喚醒前執行。

        4>測試代碼以下

public class CyclicBarrierTest {
    public static class ComponentThread implements Runnable {
        CyclicBarrier barrier;
        int id;
        int[] array;

        public ComponentThread(CyclicBarrier barrier, int[] array, int id) {
            this.barrier = barrier;
            this.array = array;
            this.id = id;
        }

        @Override
        public void run() {
            array[id] = new Random().nextInt(100);
            System.out.println("Component " + id + "generates" + array[id]);
            try {
                barrier.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
            }
            System.out.println("Component " + id + " awaked");
            int result = array[id] + array[id + 1];
            System.out.println("Component " + id + " result:" + result);
        }
    }

    public static void testCyclicBarrier() {
        final int[] array = new int[3];
        CyclicBarrier barrier = new CyclicBarrier(2, new Runnable() {

            @Override
            public void run() {
                System.out.println("test CyclicBarrier run...");
                array[2] = array[0] + array[1];
            }
        });
        new Thread(new ComponentThread(barrier, array, 0)).start();
        new Thread(new ComponentThread(barrier, array, 1)).start();
    }

    public static void main(String[] args) {
        CyclicBarrierTest.testCyclicBarrier();
    }
}