ReentrantReadWriteLock源码解析

一 概述

ReentrantReadWriteLock从字面意思上就是可重入的读写锁。读写锁的特点就简单来说就是读读之间不互斥,读写或写写之间是互斥的。今天就通过它来解开读写锁的秘密。由于这个类名称太长,后面都简称它为RRWLock。

二 案例

在解读RRWLock时,先简单看下源码中提供的一个使用场景案例(代码如下),这是一个缓存的实例,因为缓存的特点就是读大于写的,这也符合RRWLock的特性。

class CachedData {
// 实际的缓存数据
Object data;
// 缓存有效标识
volatile boolean cacheValid;
// 读写锁
final ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();

// 处理缓存数据
void processCachedData() {
    // 先加上读锁
    rwl.readLock().lock();
    // 如果缓存无效,即不存在时,执行加载缓存操作
    if (!cacheValid) {
        // 写缓存要获取写锁,但是获取写锁之前要释放读锁
        rwl.readLock().unlock();
        rwl.writeLock().lock();
        try {
            // Recheck state because another thread might have
            // acquired write lock and changed state before we did.
            // 再获取到写锁后再次判断缓存是否已被其他线程加载了(因此在lock()可能会出现自旋或阻塞等待的情况,期间其他线程可能会进行加载缓存的操作))
            if (!cacheValid) {
                // 加载缓存
                data = ...;
                // 更新缓存有效标识
                cacheValid = true;
            }
            // Downgrade by acquiring read lock before releasing write lock
            // 在释放写锁前先获取到读锁
            rwl.readLock().lock();
        } finally {
            // 释放写锁,此时仍持有读锁
            rwl.writeLock().unlock(); // Unlock write, still hold read
        }
    }

    try {
        // 使用缓存数据
        use(data);
    } finally {
        // 使用完后释放读锁
        rwl.readLock().unlock();
    }
}

}

复制代码简单总结下这个缓存案例的加锁流程:

首先获取到读锁,然后检查缓存是否有效,若有效则直接使用后释放读锁并结束;
如果获取到读锁后检查缓存为无效,则需要重新加载缓存数据,此时需要获取写锁,但是在获取写锁前必须释放读锁;
获取到写锁后再次检查缓存是否有效,避免因在获取写锁自旋或阻塞等待期间,其他线程加载了缓存的问题;
重新加载缓存并更新缓存标识为有效;
在释放写锁前先获取到读锁,避免先释放写锁,写锁立刻被其他线程获取并更新了缓存,之后再获取读锁读取的数据变成脏数据的问题;
使用缓存数据,并在用完后是否读锁;

这里先抛出2个问题,在文末有答案分析:

为什么获取写锁前要先释放读锁?
为什么释放写锁前要先获取读锁?

...内部具体源码解析 参考文末---原文链接

九 问题解答

在开篇讲完读写锁的案例后提出了两个问题,源码解析后再来回答下这个问题。
解答问题之前,先简单介绍下读写锁的一些概念:

锁升级:由读锁升级为写锁(即持有读锁的线程直接获取写锁)

锁降级:由写锁降级为读锁(即持有写锁的线程直接获取读锁)

第一个问题:为什么获取写锁前要先释放读锁?
从源码来解答就是获取写锁前会先检查锁状态是否含有读锁,并且它没有区分该读锁持有者是否为自己,如果发现存在读锁则会加入AQS队列自旋或阻塞等待。如下所示:
Thread current = Thread.currentThread();
int c = getState();
int w = exclusiveCount(c);
if (c != 0) {
// (Note: if c != 0 and w == 0 then shared count != 0)
if (w == 0 || current != getExclusiveOwnerThread())
return false;
……
}
复制代码其实这里讨论的就是锁升级的问题,从源码也可以看出,RRWLock是不支持锁升级的。因此,如果没有释放读锁而直接去获取写锁,会导致写锁阻塞。案例中如果当前线程持有读锁不释放直接获取写锁会发现死锁等待的问题。
第二个问题:为什么释放写锁前要先获取读锁?
这其实就是锁降级问题,首先说明的是,RRWLock是支持锁降级的。从获取读锁的过程中就可以看出:
Thread current = Thread.currentThread();
int c = getState();
// 如果独占锁不为空,并且持有独占锁的非当前线程才会直接失败返回
if (exclusiveCount(c) != 0 && getExclusiveOwnerThread() != current)
return -1;
复制代码在这个场景中,如果不是采用锁降级的方式,而是直接先释放写锁再去获取读锁的话,会存在这样的问题:当修改完数据并释放写锁后,读锁参与竞争锁,但是另一个写锁请求先获取到了,那么当前的读锁线程就得等待,另一个写锁线程修改完数据后释放锁,当前读锁获取到的数据已经是被修改之后了,而不是当时修改的,此时产生了脏读的问题,因此此处使用锁降级的方案能避免此问题。
通过上述两个问题,可以知道:RRWLock支持锁降级,不支持锁升级

十 总结

行文至此,RRWLock的原理也基本都讲完了,最后也简单总结下它的特点:

内部含有两把锁,读锁和写锁,允许共享读锁,但是写锁是独占锁,即同一时刻只允许一个线程进行写操作,读则允许多线程读。
内部锁的实现是通过AQS来实现的,存在读锁或写锁时,写请求加入AQS队列阻塞等待。而读请求只在存在写锁下才加入AQS队列阻塞等待。
支持锁重入,读锁使用ThreadLocal的子类为每个线程存放锁的重入次数,写锁直接使用锁状态的低位来记录锁重入次数。
RRWLock使用于读请求多但写操作少的场景中。

原文学习地址:https://juejin.im/post/5d4cdb0ae51d4561e0516ab4

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 194,088评论 5 459
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 81,715评论 2 371
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 141,361评论 0 319
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 52,099评论 1 263
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 60,987评论 4 355
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 46,063评论 1 272
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 36,486评论 3 381
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 35,175评论 0 253
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 39,440评论 1 290
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 34,518评论 2 309
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 36,305评论 1 326
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 32,190评论 3 312
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 37,550评论 3 298
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 28,880评论 0 17
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,152评论 1 250
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 41,451评论 2 341
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 40,637评论 2 335

推荐阅读更多精彩内容