在上一篇文章中已经分析过公平锁的加锁源码,并得出结论:
现在看一下加锁失败被放到等待队列之后,线程是如何处理的?
源码入口:org.redisson.RedissonLock#lock(long, java.util.concurrent.TimeUnit, boolean)
。
线程进入排队之后,在 Java 代码中会 while (true)
一直循环调用 tryAcquire
,尝试获取锁。
最终还是来到 RedissonFairLock#tryLockInnerAsync
方法中。
方便起见,重新贴一下 Lua 脚本,以及脚本的参数含义。
anyLock
;redisson_lock_queue:{anyLock}
;redisson_lock_timeout:{anyLock}
,是按照锁的时间戳存放到集合中的;a3da2c83-b084-425c-a70f-5d9a08b37f31:1
第一部分,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 代码中会不断尝试获取锁。
当锁不存在且当前线程是在等待队列头时,直接获得锁。这个排队的过程就是公平锁的提现。
- <End /> -