CyclicBarrier剖析

[TOC]

概念

用来控制多个线程互相等待，只有当多个线程都到达时，这些线程才会继续执行。
和 CountdownLatch 相似，都是通过维护计数器来实现的。线程执行 await() 方法之后计数器会减 1，并进行等待，
直到计数器为 0，所有调用 await() 方法而在等待的线程才能继续执行。

dowait();->reentrantlock

public class CyclicBarrierExample {
        public static void main(String[] args) {
        final int totalThread = 10;
        CyclicBarrier cyclicBarrier = new CyclicBarrier(totalThread);
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < totalThread; i++) {
        executorService.execute(() -> {
        System.out.print("before..");
        try {
        cyclicBarrier.await();
        } catch (InterruptedException | BrokenBarrierException e) {
        e.printStackTrace();
        }
        System.out.print("after..");
        });
        }
        executorService.shutdown();
 }
}

1 2	before..before..before..before..before..before..before..before..before..before..after..after ..after..after..after..after..after..after..after..after..

思路

JDK 的思路就是：首先，每个 CyclicBarrier 都有一个 Lock，想执行 await 方法，就必须获得这把锁.设置一个计数器，线程每调用一次计数器，就减一，并使用 Condition 阻塞线程。当计数器是0的时候，就唤醒所有线程，并尝试执行构造函数中的任务。由于 CyclicBarrier 是可重复执行的，所以，就需要重置计数器。

CyclicBarrier 还有一个重要的点，就是 generation 的概念，由于每一个线程可以使用多个 CyclicBarrier，每个 CyclicBarrier 又都可以唤醒线程，那么就需要用代来控制，如果代不匹配，就需要重新休眠。有一个 “代” 的概念，因为 CyclicBarrier 是可以复用的，那么每次所有的线程通过了栅栏，就表示一代过去了.

而他和 CountDownLatch 的区别在于，CountDownLatch 只能使用一次就 over 了，CyclicBarrier 能使用多次，可以说功能类似，CyclicBarrier 更强大一点。并且 CyclicBarrier 携带了一个在栅栏处可以执行的任务。更加灵活。