CyclicBarrier使用场景
用于协调多个线程同步执行操作的场合，所有线程等待完成,然后一起做事情( 相互之间都准备好,然后一起做事情 )
例如百米赛跑，必须等待所有运动员都准备好了，才能比赛。
运动员准备好，裁判也准备好，才能开始正式比赛。
例子
CyclicBarrier cyclicBarrier = new CyclicBarrier(3); new Thread(() -> { try { Thread.sleep(1000); System.out.println("t1 在准备 "); cyclicBarrier.await(); // 等另外一个线程准备好 然后开始做事情 System.out.println("t1 准备好了 "); } catch (InterruptedException | BrokenBarrierException e) { e.printStackTrace(); } }).start(); new Thread(() -> { try { Thread.sleep(2000); System.out.println("t2 在准备 "); cyclicBarrier.await(); // 等另外一个线程准备好 然后开始做事情 System.out.println("t2 准备好了 "); } catch (InterruptedException | BrokenBarrierException e) { e.printStackTrace(); } }).start(); System.out.println(" 裁判 在准备 "); try { cyclicBarrier.await(); } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } System.out.println(" 裁判 准备好了 "); while (true){ if (cyclicBarrier.getNumberWaiting()==0){ System.out.println(" 时间到: 开始比赛"); return; } }
关于CyclicBarrier的底层执行流程总结：
- 1、初始化CyclicBarrier中的各种成员变量，包括parties、count以及Runnable（可选）；
- 2、当调用await()方法时，底层会先检查计数器是否已经归零，如果是的话，那么就首先执行可选的Runnable，接下来开始下一个generation；（注意：这里只是调用Runnable的run()方法，并不是调用start()方法开启另一个线程）
- 3、在下一个分代中，将会重置count值为parties，并且创建新的Generation实例；
- 4、同时会调用Condition的singalAll方法，唤醒所有在屏障前面等待的线程，让其开始继续执行；（注意：当有可选的Runnable时，是执行完run()方法中的汇总操作，其他线程才会继续执行）
- 5、如果计数器没有归零，那么当前的调用线程将会通过Condition的await方法，在屏障前进行等待；
- 6、以上所有执行流程均在lock锁的控制范围内，不会出现并发情况。
- 7、在下一个分代时，该屏障又可以继续使用，例如计数器是3，线程1，线程2和线程3冲破了当前屏障后，下一个分代的屏障可以去给线程4，线程5和线程6使用，也可以又给线程1，线程2和线程3使用（自己总结的）
CyclicBarrier cyclicBarrier = new CyclicBarrier(2, new Runnable() { @Override public void run() { System.out.println("汇总 然后继续执行没有执行的部分"); } });
CountDownLatch是基于AQS实现的；而CyclicBarrier是基于ReentrantLock重入锁实现的，当然ReentrantLock也是基于AQS实现的，非要说CyclicBarrier也是基于AQS实现的也不为过。
await()方法有两层含义：
1、先检查前面是否已经有count个线程了，如果没有线程则会进入等待状态
2、当检测到屏障已经有count个线程了，则所有线程会冲出屏障继续执行（如果有Runnable参数的构造方法先执行汇总方法）
