回顾前面:
只有光头才能变强!
上一篇已经将Lock锁的基础AQS简单地过了一遍了,因此本篇主要是讲解Lock锁主要的两个子类:
那么接下来我们就开始吧~
首先我们来看看ReentrantLock锁的 顶部注释 ,来看看他的相关特性呗:
来总结一下要点吧:
class X { private final ReentrantLock lock = new ReentrantLock(); // ... public void m() { lock.lock(); // block until condition holds try { // ... method body } finally { lock.unlock() } } }
首先我们可以看到有三个内部类:
这些内部类都是AQS的子类,这就印证了我们之前所说的: AQS是ReentrantLock的基础,AQS是构建锁、同步器的框架
尝试获取锁,获取失败的话就调用AQS的 acquire(1)
方法
acquire(1)
方法我们在AQS时简单看过,其中 tryAcquire()
是子类来实现的
我们去看看 tryAcquire()
:
公平的lock方法其实就 多了一个状态条件 :
这个方法主要是判断 当前线程是否位于CLH同步队列中的第一个。如果是则返回flase,否则返回true 。
unlock方法也是在AQS中定义的:
去看看 tryRelease(arg)
是怎么实现的:
我们知道synchronized内置锁和ReentrantLock都是 互斥锁 (一次只能有一个线程进入到临界区(被锁定的区域))
而ReentrantReadWriteLock是一个 读写锁 :
一般来说:我们大多数都是读取数据得多,修改数据得少。所以这个读写锁在这种场景下就很有用了!
读写锁有一个接口ReadWriteLock,定义的方法就两个:
我们还是来看看顶部注释说得啥吧:
其实大概也是说明了: 在读的时候可以共享,在写的时候是互斥的
接下来我们还是来看看对应的实现类吧:
按照惯例也简单看看它的顶部注释:
于是我们可以总结出读写锁的一些要点了:
ReentrantReadWriteLock比ReentrantLock锁 多了两个内部类(都是Lock实现)来维护读锁和写锁 ,但是 主体还是使用Syn :
在ReentrantLock锁上使用的是state来表示同步状态(也可以表示重入的次数),而在ReentrantReadWriteLock是这样代表读写状态的:
主要还是调用syn的 acquire(1)
:
进去看看实现:
写锁的获取调用的是 acquireShared(int arg)
方法:
内部调用的是: doAcquireShared(arg);
方法(实现也是在Syn的),我们来看看:
这里就简单总结一下本文的内容吧:
总的来说看多线程源码难度系数还是好高啊,我目前的水平只能过一过了....
多线程后面还有挺多高深的知识点:Future、同步容器啊、阻塞队列、各种原子类啊等等等, 这里我打算就先放一放了 ,目前的水平有限啊~~~~~
后面可能会有一篇线程池的博文,敬请期待咯~
有兴趣的同学可继续往下面的参考资料下学习~~~
参考资料:
如果文章有错的地方欢迎指正,大家互相交流。习惯在微信看技术文章,想要获取更多的Java资源的同学,可以 关注微信公众号:Java3y 。为了大家方便,刚新建了一下 qq群:742919422 ,大家也可以去交流交流。谢谢支持了!希望能多介绍给其他有需要的朋友