透彻理解 Java 并发编程
首页 死磕 Java 优质系列 Java 技术总览 Java 面试宝典 关于我

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

转
 2023-08-15  阅读(3)
©版权
原文作者：Ressmix 原文地址：https://www.tpvlog.com/article/18

一、本章概述

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的两个子类，分别代表了实现公平策略和非公平策略的同步器：

202308152157542201.png

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

202308152157548172.png

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

202308152157554073.png

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

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

202308152157561744.png

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

  1. 写锁没有被其它线程占用（可被当前线程占用，这种情况属于锁降级）
  2. 等待队列中的队首没有其它线程（公平策略）
  3. 读锁重入次数没有达到最大值
  4. CAS操作修改同步状态值State成功

202308152157576315.png

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

202308152157586876.png

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

202308152157596737.png

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

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

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

202308152158000778.png

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

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

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

202308152158005739.png

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

  1. 当前线程已经持有写锁
  2. 写锁未被占用

2023081521580119110.png

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

2023081521580215611.png

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

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

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

2023081521580272212.png

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

2023081521580357113.png

最终等待队列结构如下：

2023081521580458214.png

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

6. ThreadA释放读锁

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

2023081521580516415.png

2023081521580568616.png

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

2023081521580632317.png

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

2023081521580735418.png

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

7. ThreadB释放读锁

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

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

8. ThreadD释放读锁

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

2023081521580796519.png

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

2023081521580856020.png

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

2023081521580917721.png

该操作会将ThreadC唤醒：

2023081521580995322.png

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

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

2023081521581057323.png

等待队列最终状态：

2023081521581138124.png

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

10. ThreadC释放写锁

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

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

2023081521581184025.png

四、总结

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

2023081521581232926.png

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

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

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

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

Java 面试宝典是大明哥全力打造的 Java 精品面试题，它是一份靠谱、强大、详细、经典的 Java 后端面试宝典。它不仅仅只是一道道面试题，而是一套完整的 Java 知识体系，一套你 Java 知识点的扫盲贴。

它的内容包括：

  • 大厂真题：Java 面试宝典里面的题目都是最近几年的高频的大厂面试真题。
  • 原创内容：Java 面试宝典内容全部都是大明哥原创，内容全面且通俗易懂，回答部分可以直接作为面试回答内容。
  • 持续更新：一次购买，永久有效。大明哥会持续更新 3+ 年，累计更新 1000+，宝典会不断迭代更新，保证最新、最全面。
  • 覆盖全面：本宝典累计更新 1000+，从 Java 入门到 Java 架构的高频面试题，实现 360° 全覆盖。
  • 不止面试：内容包含面试题解析、内容详解、知识扩展，它不仅仅只是一份面试题，更是一套完整的 Java 知识体系。
  • 宝典详情：https://www.yuque.com/chenssy/sike-java/xvlo920axlp7sf4k
  • 宝典总览：https://www.yuque.com/chenssy/sike-java/yogsehzntzgp4ly1
  • 宝典进展：https://www.yuque.com/chenssy/sike-java/en9ned7loo47z5aw

目前 Java 面试宝典累计更新 400+ 道，总字数 42w+。大明哥还在持续更新中，下图是大明哥在 2024-12 月份的更新情况：

想了解详情的小伙伴，扫描下面二维码加大明哥微信【daming091】咨询

同时，大明哥也整理一套目前市面最常见的热点面试题。微信搜[大明哥聊 Java]或扫描下方二维码关注大明哥的原创公众号[大明哥聊 Java] ，回复【面试题】 即可免费领取。

阅读全文
文章标签： Java 并发