CyclicBarrier使用

CyclicBarrier循环屏障（障碍），同样都是jdk线程并发包下的java.util.concurrent,底层使用ReentrantLock可重入锁，共享资源重复加锁，该线程获取锁不被阻塞。
使用场景：约好4个人一起打麻将，如果是三缺一就无法进行，三个人需要等待1人，四个人达到麻将馆即可开战。
或者处理间断，反复请求时，避免一条条的处理，定义规则满足10次提交一次业务流，当不满足10次，一直阻塞等待。

/**
 *  CyclicBarrier 循环屏障
 *  jdk："一种同步帮助,允许一组线程等待所有线程,互相达到一个共同的障碍点",大白话讲：满足n个线程数量，才能访问后续动作，不满足就一直等待。
 */
public class CyclicBarrierTest {

    public static final Logger logger = LoggerFactory.getLogger(CyclicBarrierTest.class);

    public static void main(String[] args) {

        /**
         * Creates a new {@code CyclicBarrier} that will trip when the
         * given number of parties (threads) are waiting upon it, and
         * does not perform a predefined action when the barrier is tripped.
         *
         * @param parties the number of threads that must invoke {@link #await}
         *        before the barrier is tripped
         * @throws IllegalArgumentException if {@code parties} is less than 1
         */

        //定义5个循环障碍，5个线程执行完后,会解除阻塞，计数清零。然后循环重复此规则
        CyclicBarrier cyclicBarrier = new CyclicBarrier(5);

        //定义一个缓存线程池,如果有空闲的线程进行回收，否则创建新的线程
        ExecutorService executors = Executors.newCachedThreadPool();

        //这里可以模拟不同的请求数来验证，第一次可以循环5次，第二次循环6次，第三次循环10次，来观察不同之处
        //循环5次，刚好一组任务完成。
        //循环6次，只能满足第一组任务，第二组任务将一直等待，阻塞任务。
        //循环十次，两组任务都可以完成。
        for (int i = 0; i < 10; i++) {
            executors.execute(() -> {
                logger.info(Thread.currentThread().getName() + "进入考场");
                try {
                    //dowait方法ReentrantLock  可重入锁
                    cyclicBarrier.await();

                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
                logger.info(Thread.currentThread().getName() + "开始考试...");
            });
        }

        executors.shutdown();
    }
}

日中输出：

18:05:19.283 [pool-1-thread-3] INFO com.test.tenant.CyclicBarrierTest - pool-1-thread-3进入考场
18:05:19.283 [pool-1-thread-4] INFO com.test.tenant.CyclicBarrierTest - pool-1-thread-4进入考场
18:05:19.283 [pool-1-thread-5] INFO com.test.tenant.CyclicBarrierTest - pool-1-thread-5进入考场
18:05:19.283 [pool-1-thread-1] INFO com.test.tenant.CyclicBarrierTest - pool-1-thread-1进入考场
18:05:19.283 [pool-1-thread-2] INFO com.test.tenant.CyclicBarrierTest - pool-1-thread-2进入考场
18:05:19.286 [pool-1-thread-3] INFO com.test.tenant.CyclicBarrierTest - pool-1-thread-3开始考试...
18:05:19.286 [pool-1-thread-5] INFO com.test.tenant.CyclicBarrierTest - pool-1-thread-5开始考试...
18:05:19.286 [pool-1-thread-4] INFO com.test.tenant.CyclicBarrierTest - pool-1-thread-4开始考试...
18:05:19.286 [pool-1-thread-2] INFO com.test.tenant.CyclicBarrierTest - pool-1-thread-2开始考试...
18:05:19.286 [pool-1-thread-1] INFO com.test.tenant.CyclicBarrierTest - pool-1-thread-1开始考试...

CyclicBarrier 和CountDownLatch区别：

阻塞区别：
CountDownLatch某一个或多个线程 ，等待其他线程执行完成之后，才能继续执行。父线程等待子线程执行完成，才能继续执行。
CyclicBarrier 一组线程互相等待，任何一个未执行完成，其他线程都需要等待。10个线程，全部完成，才能执行后续动作。

使用次数区别：
CountDownLatch倒计时门闩，每执行一次都是递减1，await等于0时，结束阻塞，不可重复使用
CyclicBarrier循环屏障，每执行一次都是递加1，barrier释放完后，可继续使用，重复循环使用。

锁区别
CountDownLatch 内部使用 Sync AQS 状态来控制，volatile可见性控制线程间变量共享
CyclicBarrier内部使用ReentrantLock可重入锁