CyclicBarrier的字面意思是可循环（Cyclic）使用的屏障（Barrier），它要做的事情是，让一组线程到达一个屏障（也可以叫同步点）时被阻塞，直到最后一个线程到达屏障时，屏障才会开门，所有被屏障拦截的线程才会继续干活，线程进入屏障通过CyclicBarrier的await方法，它也是做线程间调度， 举一个生活的例子，正常情况下，我们平时工作中开会，只有等人到齐后，会议才可以开始，我们来一个demo。
import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierDemo {
public static void main(String[] args) throws Exception {
CyclicBarrier cb = new CyclicBarrier(6, () -> System.err.println("会议开始"));
for (int i = 1; i < 7; i++) {
new Thread(() -> { System.err.println(Thread.currentThread().getName() + "进入会议室"); try { cb.await(); } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } }, "第" + i+"个人").start(); }
}
}
执行结果
第1个人进入会议室 第6个人进入会议室 第5个人进入会议室 第3个人进入会议室 第2个人进入会议室 第4个人进入会议室 会议开始
从执行结果来看，实现了人到齐开会的需求，CyclicBarrier做加法CountDownLatch做减法，关于CountDownLatch用法可看下我前一篇文章，下篇见。
原来CountDownLatch是用于线程间的调度
