前言
在上一篇文章中曾经剖析过偏心锁的加锁源码,并得出结论:
- Redis Hash 数据结构:寄存以后锁,Redis Key 就是锁,Hash 的 field 是加锁线程,Hash 的 value 是 重入次数;
- Redis List 数据结构:充当线程期待队列,新的期待线程会应用 rpush 命令放在队列左边;
- Redis sorted set 有序汇合数据结构:寄存期待线程的程序,分数 score 用来是期待线程的超时工夫戳。
当初看一下加锁失败被放到期待队列之后,线程是如何解决的?
排队等锁
源码入口:org.redisson.RedissonLock#lock(long, java.util.concurrent.TimeUnit, boolean)
。
线程进入排队之后,在 Java 代码中会 while (true)
始终循环调用 tryAcquire
,尝试获取锁。
最终还是来到 RedissonFairLock#tryLockInnerAsync
办法中。
不便起见,从新贴一下 Lua 脚本,以及脚本的参数含意。
- KEYS[1]:加锁的名字,
anyLock
; - KEYS[2]:加锁期待队列,
redisson_lock_queue:{anyLock}
; - KEYS[3]:期待队列中线程锁工夫的 set 汇合,
redisson_lock_timeout:{anyLock}
,是依照锁的工夫戳寄存到汇合中的; - ARGV[1]:锁超时工夫 30000
- ARGV[2]:UUID:ThreadId 组合
a3da2c83-b084-425c-a70f-5d9a08b37f31:1
- ARGV[3]:threadWaitTime 默认 300000
- ARGV[4]:currentTime 以后工夫戳
源码剖析
第一局部,while 循环:
- 从期待队列
redisson_lock_queue:{anyLock}
中获取第一个期待线程; - 从期待线程超时汇合
redisson_lock_timeout:{anyLock}
中获取第一个期待线程的分数; - 没有超时,间接完结,超时了,则间接移除。
第二局部,以后锁存在,间接跳过。
第三局部,以后锁不是持锁线程,间接跳过。
第四局部,
间接返回以后锁还有多久到期。
以后 Redisson 版本为 3.15.6,不同版本的略有不同。
队列重排
这里不存在从新排序,因为官网认为这是一个 bug,从新进行了修复。
具体能够浏览:Justin Corpron 2019/5/10, 04:13 Fix timeout drift in RedissonFairLock
最大的变动就是减少了第四局部。
图仅仅代表两个版本的差异,并不是代表这个版本才批改。
总结
当线程获取锁失败,进入到期待队列时,ttl != null
,在 Java 代码中会一直尝试获取锁。
当锁不存在且以后线程是在期待队列头时,间接取得锁。这个排队的过程就是偏心锁的提现。
相干举荐
- Redisson 分布式锁源码 05:偏心锁加锁
- Redisson 分布式锁源码 04:可重入锁开释
- Redisson 分布式锁源码 03:可重入锁互斥