Java多线程进阶（十）—— J.U.C之locks框架：基于AQS的读写锁(5)

dunizb 发布于2019-08-19 10:50 / 1808人阅读

摘要：关于，最后有两点规律需要注意当的等待队列队首结点是共享结点，说明当前写锁被占用，当写锁释放时，会以传播的方式唤醒头结点之后紧邻的各个共享结点。当的等待队列队首结点是独占结点，说明当前读锁被使用，当读锁释放归零后，会唤醒队首的独占结点。

本文首发于一世流云的专栏：https://segmentfault.com/blog...

一、本章概述

AQS系列的前四个章节，已经分析了AQS的原理，本章将会从ReentrantReadWriteLock出发，给出其内部利用AQS框架的实现原理。

ReentrantReadWriteLock（以下简称RRW），也就是读写锁，是一个比较特殊的同步器，特殊之处在于其对同步状态State的定义与ReentrantLock、CountDownLatch都很不同。通过RRW的分析，我们可以更深刻的了解AQS框架的设计思想，以及对“什么是资源？如何定义资源是否可以被访问？”这一命题有更深刻的理解。

关于ReentrantReadWriteLock的使用和说明，读者可以参考：Java多线程进阶（四）—— juc-locks锁框架：ReentrantReadWriteLock

二、本章示例

和之前的章节一样，本章也通过示例来分析RRW的源码。

假设现在有4个线程，ThreadA、ThreadB、ThreadC、ThreadD。
ThreadA、ThreadB、ThreadD为读线程，ThreadC为写线程：初始时，构造RRM对象：
private final ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();
private final Lock r = rwl.readLock();
private final Lock w = rwl.writeLock();

//ThreadA调用读锁的lock()方法

//ThreadB调用读锁的lock()方法

//ThreadC调用写锁的lock()方法

//ThreadD调用读锁的lock()方法

三、RRW的公平策略原理 1. RRW对象的创建

和ReentrantLock类似，ReentrantReadWriteLock的构造器可以选择公平/非公平策略（默认为非公平策略），RRW内部的FairSync、NonfairSync是AQS的两个子类，分别代表了实现公平策略和非公平策略的同步器：

ReentrantReadWriteLock提供了方法，分别获取读锁/写锁：

ReentrantReadWriteLock.ReadLock和ReentrantReadWriteLock.WriteLock其实就是两个实现了Lock接口的内部类:

2. ThreadA调用读锁的lock()方法

读锁其实是一种共享锁，实现了AQS的共享功能API，可以看到读锁的内部就是调用了AQS的acquireShared方法，该方法前面几章我们已经见过太多次了：

关键来看下ReentrantReadWriteLock是如何实现tryAcquireShared方法的：
读锁获取成功的条件如下：

写锁没有被其它线程占用（可被当前线程占用，这种情况属于锁降级）

等待队列中的队首没有其它线程（公平策略）

读锁重入次数没有达到最大值

CAS操作修改同步状态值State成功

如果CAS操作失败，会调用fullTryAcquireShared方法，自旋修改State值：

ThreadA调用完lock方法后，等待队列结构如下：

此时：
写锁数量：0
读锁数量：1

3. ThreadB调用读锁的lock()方法

由于读锁是共享锁，且此时写锁未被占用，所以此时ThreadB也可以拿到读锁：
ThreadB调用完lock方法后，等待队列结构如下：

此时：
写锁数量：0
读锁数量：2

4. ThreadC调用写锁的lock()方法

写锁其实是一种独占锁，实现了AQS的独占功能API，可以看到写锁的内部就是调用了AQS的acquire方法，该方法前面几章我们已经见过太多次了：

关键来看下ReentrantReadWriteLock是如何实现tryAcquire方法的，并没有什么特别，就是区分了两种情况：

当前线程已经持有写锁

写锁未被占用

ThreadC调用完lock方法后，由于存在使用中的读锁，所以会调用acquireQueued并被加入等待队列，这个过程就是独占锁的请求过程（AQS[二]），等待队列结构如下：

此时：
写锁数量：0
读锁数量：2

5. ThreadD调用读锁的lock()方法

这个过程和ThreadA和ThreadB几乎一样，读锁是共享锁，可以重复获取，但是有一点区别：
由于等待队列中已经有其它线程（ThreadC）排在当前线程前，所以readerShouldblock方法会返回true，这是公平策略的含义。

虽然获取失败了，但是后续调用fullTryAcquireShared方法，自旋修改State值，正常情况下最终修改成功，代表获取到读锁：

最终等待队列结构如下：

此时：
写锁数量：0
读锁数量：3

6. ThreadA释放读锁

内部就是调用了AQS的releaseShared方法，该方法前面几章我们已经见过太多次了：

关键来看下ReentrantReadWriteLock是如何实现tryReleaseShared方法的，没什么特别的，就是将读锁数量减1：

注意：
HoldCounter是个内部类，通过与ThreadLocal结合使用保存每个线程的持有读锁数量，其实是一种优化手段。

此时：
写锁数量：0
读锁数量：2

7. ThreadB释放读锁

和ThreadA的释放完全一样，此时：

写锁数量：0
读锁数量：1

8. ThreadD释放读锁

和ThreadA的释放几乎一样，不同的是此时读锁数量为0，tryReleaseShared方法返回true：

此时：
写锁数量：0
读锁数量：0

因此，会继续调用doReleaseShared方法，doReleaseShared方法之前在讲AQS[四]时已经阐述过了，就是一个自旋操作：

该操作会将ThreadC唤醒：

9. ThreadC从原阻塞处继续向下执行

ThreadC从原阻塞处被唤醒后，进入下一次自旋操作，然后调用tryAcquire方法获取写锁成功，并从队列中移除:

等待队列最终状态：

此时：
写锁数量：1
读锁数量：0

10. ThreadC释放写锁

其实就是独占锁的释放，在AQS[二]中，已经阐述过了，不再赘述。

补充一点：如果头结点后面还有等待的共享结点，会以传播的方式依次唤醒，这个过程就是共享结点的唤醒过程，并无区别。

四、总结

本章通过ReentrantReadWriteLock的公平策略，分析了RRW的源码，非公平策略分析方法也是一样的，非公平和公平的最大区别在于写锁的获取上：

在非公平策略中，写锁的获取永远不需要排队，这其实时性能优化的考虑，因为大多数情况写锁涉及的操作时间耗时要远大于读锁，频次远低于读锁，这样可以防止写线程一直处于饥饿状态。

关于ReentrantReadWriteLock，最后有两点规律需要注意：

当RRW的等待队列队首结点是共享结点，说明当前写锁被占用，当写锁释放时，会以传播的方式唤醒头结点之后紧邻的各个共享结点。

当RRW的等待队列队首结点是独占结点，说明当前读锁被使用，当读锁释放归零后，会唤醒队首的独占结点。

ReentrantReadWriteLock的特殊之处其实就是用一个int值表示两种不同的状态（低16位表示写锁的重入次数，高16位表示读锁的使用次数），并通过两个内部类同时实现了AQS的两套API，核心部分与共享/独占锁并无什么区别。

云服务器 GPU云服务器 java多线程同步锁多线程 java 同步锁 java读写锁的作用多服务器之间线程锁

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/76550.html

Java多线程进阶（一）—— J.U.C并发包概述

摘要：整个包，按照功能可以大致划分如下锁框架原子类框架同步器框架集合框架执行器框架本系列将按上述顺序分析，分析所基于的源码为。后，根据一系列常见的多线程设计模式，设计了并发包，其中包下提供了一系列基础的锁工具，用以对等进行补充增强。 showImg(https://segmentfault.com/img/remote/1460000016012623); 本文首发于一世流云专栏：https...

anonymoussf 2019-08-16 12:40 评论0 收藏0
Java多线程进阶（二）—— J.U.C之locks框架：接口

摘要：二接口简介可以看做是类的方法的替代品，与配合使用。当线程执行对象的方法时，当前线程会立即释放锁，并进入对象的等待区，等待其它线程唤醒或中断。 showImg(https://segmentfault.com/img/remote/1460000016012601); 本文首发于一世流云的专栏：https://segmentfault.com/blog... 本系列文章中所说的juc-...

dkzwm 2019-08-16 12:41 评论0 收藏0
Java多线程进阶（九）—— J.U.C之locks框架：AQS共享功能剖析(4)

摘要：好了，继续向下执行，尝试获取锁失败后，会调用首先通过方法，将包装成共享结点，插入等待队列，插入完成后队列结构如下然后会进入自旋操作，先尝试获取一次锁，显然此时是获取失败的主线程还未调用，同步状态还是。 showImg(https://segmentfault.com/img/remote/1460000016012541); 本文首发于一世流云的专栏：https://segmentfa...

CompileYouth 2019-08-19 10:50 评论0 收藏0
Java多线程进阶（八）—— J.U.C之locks框架：AQS的Conditon等待(3)

摘要：关于接口的介绍，可以参见多线程进阶二锁框架接口。最终线程释放了锁，并进入阻塞状态。当线程被通知唤醒时，则是将条件队列中的结点转换成等待队列中的结点，之后的处理就和独占功能完全一样。 showImg(https://segmentfault.com/img/remote/1460000016012490); 本文首发于一世流云的专栏：https://segmentfault.com/bl...

ityouknow 2019-08-19 10:50 评论0 收藏0
Java多线程进阶（三）—— J.U.C之locks框架：ReentrantLock

摘要：公平策略在多个线程争用锁的情况下，公平策略倾向于将访问权授予等待时间最长的线程。使用方式的典型调用方式如下二类原理的源码非常简单，它通过内部类实现了框架，接口的实现仅仅是对的的简单封装，参见原理多线程进阶七锁框架独占功能剖析 showImg(https://segmentfault.com/img/remote/1460000016012582); 本文首发于一世流云的专栏：https...

jasperyang 2019-08-16 12:41 评论0 收藏0