一、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);
先是获取线程锁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大佬,若知此解,求答!!!】
这里的空,都是你的-->