一、CyclicBarrier【栅栏】【非公平锁】
轻车驾熟，依旧是先抛去底层详细的实现。
CyclicBarrier类
1.1、成员变量：
final ReentrantLock lock; CyclicBarrier类中重要的工具类，主要是提供了lock()、unlock()、以及创建线程阻塞队列newCondition();
final Condition trip; 线程阻塞队列容器，管理线程的同时，还提供类似于Object唤醒线程的一系列方法接口。例子如：（await()类似Object.await()、signal()类似Object.notify()、signalAll()类似于Object.notifyAll()）
final int parties; 栅栏打开的临界点。当线程数==parties打开，否则一直关闭。
final Runnable barrierCommand; 栅栏打开后，后续操作。
Generation generation; 为了重复这个栅栏类，每当栅栏重新关闭，generation会重新初始化。这也是为什么不用final修饰它的原因。
int count; count初始值==parties。每当一个线程到达栅栏钱，count递减。直到count==0临界值，即栅栏拦截的线程数==pariter时，栅栏打开。
1.2、成员函数：
CyclicBarrier(int parties); 初始化变量parties。
CyclicBarrier(int parties, Runnable barrierAction); 初始化变量parties，并设置变量barrierCommand。
await()/await(long timeout, TimeUnit unit); 功能类似，即将线程挂起，最终都是调用dowait()。
dowait(boolean timed, long nanos);
dowait()函数
先是获取线程锁lock.lock(); 这将会获取到类似sychroninzed的锁，但也仅是功能上相似，实现原理完全不同。关于ReentrantLock锁机制可见链接【1.锁场景理解； 2.锁实现原理理解】
再是if(index == 0)的判断，即当线程数达到栅栏上限，门阀打开；打开之前，还做了一个判断(command != null)，即之前传参给barrierCommand变量，如果它不为空，run()运行它；接下来时nextGeneration()，这个主要做了两件事：trip.signalAll()[trip是同步队列变量]，调用此函数，唤醒所有的线程；再是count=parties，重新设置count值。
接下来是CAS操作，记住传参进来时timed=false，nanos=0L。所以，这里主要执行trip.await()，即时当线程数未达到门阀值，执行线程挂起操作。
最后是finally{ lock。unlock(); } 很重要。目的是避免死锁，这其中原由还是得深入ReentrantLock锁机制才行。
二、问答环节
2.1、构造函数中public CyclicBarrier(int parties, Runnable barrierAction)，能更深入讲解如何使用嘛？
如果你能深入点源码，你就能很清晰的知道多了个barrierAction参数作用啦。parties之前讲过，对于barrierAction，我们可以形象理解。举个例：有十位将军要进京面圣，他们约定到了都城门在一起进去。于是乎，一位、两位、三位...等到人齐了，都城门就打开了。打开后，王上命令将军们先等会，等太监们铺红地毯再进来。于是太监们就action起来，也就是barrierAction.run()。然后将军们再继续的前进、运行起来。
2.2、public void reset()，作用是什么呢？
不知道。能力有限，本想自己尝试过，再进行自己的解释。但在本地执行reset()时，没有得到我想要的结果。那么肯定是我理解有误啦，遂不敢多bb.【各位Javaer大佬，若知此解，求答！！！】
这里的空，都是你的-->
网友评论