AQS-用配钥匙和保险箱理解可重入锁(ReentrantLock)

今天我们来学习可重入排他锁,它同样是JUC包下使用AQS同步框架来实现的,因此代码比较简洁,只要了解了AQS的原理那么就会觉得it is so easy。

1 怎么理解可重入锁

排他,说明锁只能被一人占有(就类似信号量(semaphore)为1,每一时刻只能有一人拥有)。可重入,同一个人可以多次使用同一资源,这非常合理。试想一下,当一只保险箱的钥匙归你所属后,难道你不能再去锁匠那再配一把来开箱子吗?在这个法制社会里,钥匙是你的,那你去配钥匙肯定是合法的,至于你为什么要配钥匙呢?一家人嘛,不过我相信你不可能把备份钥匙给别人用的吧,毕竟保险箱的东西可都是你们一家人,如果给了别人一份备用钥匙,那就不可想象喽。(这个和信号量有区别,信号量是每次使用都是需要获取凭证的,它可不管你们是不是一家人。不过其主要原因是两者关注点不同:信号量主要是关注的进入的量多少,而锁是为了保护资源的0安全,而为了安全,需要怎么做呢?当然确保是一家人喽)。

2 可重入锁(ReentrantLock)的condition

在分析源码之前,我们先简单来讲一下condition。Java Lock接口定义中有一个newCondition()方法,返回condition,而这个condition要实现的效果就类似于java中的wait/notify一致。也就是说这个condition的出现其实就是为了替代它(因为使用这个经常出错)。这里我们简单讲一下原理,有兴趣的小伙伴可以自行看一下源码,这里不再赘述:由于它还是使用了AQS的框架(其内部保持着一个同步队列,可以获取锁),那么为了实现等待和唤醒,它又增加了一个等待队列,当调用await方法时,节点加入到这个等待队列中。而当调用signal方法时,只要把节点从等待队列中拿出来再放到同步队列中,让其有机会去获取锁了,condition这个实现逻辑非常的清晰,也非常简洁,可见功底非同一般(T_T 我什么时候能达到这个程度啊)。

顺带提几句:

  1. 虽然这个方法可以很方便的实现生产者/消费者模型,但是java JUC包下其实已经有一个类(就是使用了ReentrantLock的condition)实现其功能了:LinkedBlockingQueue类(嘻嘻,没想到吧。)

  2. AQS-用团购的方式理解闭锁(CountDownLatch)这篇文章中我们有提到过能实现类似的功能的CyclicBarrier,其原理也用到了这个condition。感兴趣的小伙伴们可以去看看其实现哦。

3 可重入锁(ReentrantLock)源码分析

现在我们来看看锁的源码吧。对于锁而言,我们常用的方法有lock和unlock.。我们以开保险箱的情景来描述一下其实现。

构造函数:

// 规定一下,拿钥匙的排队规则:是否需要严格排队。
// 默认是false(吞吐量更大,因为公平锁带来更多上下文切换)。
 public ReentrantLock(boolean fair)

Fair:是否公平。和之前讲的信号量等类似,如果安全,则人必须按照排队的顺序来拿钥匙,否则后面来的人也有机会获取锁。

Lock 获取锁:(也可能是配锁):

 public void lock() {
        sync.lock();
    }
​
// 以非公平为例,公平的逻辑与信号量实现一致 会先判断是否前面有人排队,
final void lock() {
            if (compareAndSetState(0, 1))  // 尝试获取原装锁                setExclusiveOwnerThread(Thread.currentThread());  // 标记是谁获取锁的人
            else
                acquire(1);   // 实际调用tryAcquire方法
        }
​
        protected final boolean tryAcquire(int acquires) {
            return nonfairTryAcquire(acquires);
        }
​
 final boolean nonfairTryAcquire(int acquires) {
            final Thread current = Thread.currentThread();
            int c = getState();
            if (c == 0) {
                if (compareAndSetState(0, acquires)) {  // 尝试获取锁
                    setExclusiveOwnerThread(current);
                    return true;
                }
            }
            else if (current == getExclusiveOwnerThread()) {  // 可重入逻辑
                int nextc = c + acquires;
                if (nextc < 0) // overflow
                    throw new Error("Maximum lock count exceeded"); // 钥匙是会用坏的,次数有点多了。
                setState(nextc);
                return true;
            }
            return false;
        }

当人获取锁后呢,会记录下锁的拥有者。为什么要记录呢?当然是为了方便下一次这个家庭的人要使用保险箱,要拿钥匙需要去锁匠那里再配一把。具体分析一下代码:

if (compareAndSetState(0, 1)): 尝试获取原装锁。

**setExclusiveOwnerThread(current): **记录获取钥匙的人,其实就是宝箱现在属于这个家庭了

else if (current == getExclusiveOwnerThread()) :是不是钥匙的所属人一个家庭的,是的话他可以重新配一把钥匙哦。同时之后要记录保险箱一共有多少把钥匙了(方便后面归还,法制社会要保证保险箱绝对安全,必须所有钥匙都归还)。


锁的释放:(保险箱钥匙要传承给别人了,可是这么多钥匙都要还啊,不然谁知道你会不会后面来偷开别人的宝箱呢)

public void unlock() {
        sync.release(1);
    }
​
protected final boolean tryRelease(int releases) {
            int c = getState() - releases;  // 释放了钥匙,还有几把在外面没有还
            if (Thread.currentThread() != getExclusiveOwnerThread())
                throw new IllegalMonitorStateException();
            boolean free = false;
            if (c == 0) {   // 钥匙全还了
                free = true;
                setExclusiveOwnerThread(null); // 把宝箱所属人清空。
            }
            setState(c);
            return free;
        }

释放的逻辑非常简单,就是把所有外借的钥匙包括备份钥匙都归还了,那宝箱又成了无主之物。后面排队的人就又可以继续来获取钥匙了,同时也不用担心这个保险箱会有其备份钥匙在别人手上了。

  • 推荐阅读 -

用火车购票的方式打开 AQS同步器(一)

用火车购票的方式打开 AQS同步器(二)

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