关于java:Redisson-分布式锁源码-06公平锁排队加锁

前言

在上一篇文章中曾经剖析过偏心锁的加锁源码，并得出结论：

1. Redis Hash 数据结构：寄存以后锁，Redis Key 就是锁，Hash 的 field 是加锁线程，Hash 的 value 是 重入次数；
2. Redis List 数据结构：充当线程期待队列，新的期待线程会应用 rpush 命令放在队列左边；
3. Redis sorted set 有序汇合数据结构：寄存期待线程的程序，分数 score 用来是期待线程的超时工夫戳。

当初看一下加锁失败被放到期待队列之后，线程是如何解决的？

排队等锁

源码入口：org.redisson.RedissonLock#lock(long, java.util.concurrent.TimeUnit, boolean)。

线程进入排队之后，在 Java 代码中会 while (true) 始终循环调用 tryAcquire，尝试获取锁。

最终还是来到 RedissonFairLock#tryLockInnerAsync 办法中。

不便起见，从新贴一下 Lua 脚本，以及脚本的参数含意。

1. KEYS[1]：加锁的名字，anyLock；
2. KEYS[2]：加锁期待队列，redisson_lock_queue:{anyLock}；
3. KEYS[3]：期待队列中线程锁工夫的 set 汇合，redisson_lock_timeout:{anyLock}，是依照锁的工夫戳寄存到汇合中的；
4. ARGV[1]：锁超时工夫 30000
5. ARGV[2]：UUID:ThreadId 组合 a3da2c83-b084-425c-a70f-5d9a08b37f31:1
6. ARGV[3]：threadWaitTime 默认 300000
7. ARGV[4]：currentTime 以后工夫戳

源码剖析

第一局部，while 循环：

1. 从期待队列 redisson_lock_queue:{anyLock} 中获取第一个期待线程；
2. 从期待线程超时汇合 redisson_lock_timeout:{anyLock} 中获取第一个期待线程的分数；
3. 没有超时，间接完结，超时了，则间接移除。

第二局部，以后锁存在，间接跳过。

第三局部，以后锁不是持锁线程，间接跳过。

第四局部，

间接返回以后锁还有多久到期。

以后 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：可重入锁互斥