您现在的位置是:亿华云 > 域名
Redisson 分布式锁源码之公平锁排队加锁
亿华云2025-10-04 01:11:16【域名】1人已围观
简介前言在上一篇文章中已经分析过公平锁的加锁源码,并得出结论:Redis Hash 数据结构:存放当前锁,Redis Key 就是锁,Hash 的 field 是加锁线程,Hash 的 value 是 重
前言
在上一篇文章中已经分析过公平锁的分布加锁源码,并得出结论:
Redis Hash 数据结构:存放当前锁,式锁Redis Key 就是源码锁,Hash 的平锁排队 field 是加锁线程,Hash 的加锁 value 是 重入次数;
Redis List 数据结构:充当线程等待队列,新的分布等待线程会使用 rpush 命令放在队列右边;
Redis sorted set 有序集合数据结构:存放等待线程的顺序,分数 score 用来是式锁等待线程的超时时间戳。
现在看一下加锁失败被放到等待队列之后,源码线程是平锁排队如何处理的?
1排队等锁
源码入口: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
最大的变化就是增加了第四部分。
图仅仅代表两个版本的差别,并不是代表这个版本才修改。
2总结
当线程获取锁失败,进入到等待队列时,ttl != null,在 Java 代码中会不断尝试获取锁。
当锁不存在且当前线程是在等待队列头时,直接获得锁。这个排队的过程就是公平锁的提现。
本文转载自微信公众号「程序员小航」,可以通过以下二维码关注。转载本文请联系程序员小航公众号。亿华云计算
很赞哦!(4471)
相关文章
- a、变更前的公司证件扫描件(代码证或者营业执照)及联系人身份证复印件、变更后的公司证件扫描件(代码证或者营业执照)及新的联系人身份证复印件;身份证复印件需本人签名,公司证件复印件需加盖公章。
- 光知道分库分表可不敢直接去面试,分表后读扩散怎么解决才是重点
- Redis 哈希表 VS Java HaspMap , 哪家强?
- Oracle OCI 计算、存储、网络工具旨在降低云复杂性
- 为什么大家都选优质域名?到底存在着什么好处?
- MySQL 游标的定义与使用
- 推荐一个好用的以多tab标签方式打开windows CMD的工具
- 小白卖域名怎么卖?有什么域名交易技巧?
- 一下域名,看有没有显示出你所解析的IP,如果有,就说明解析是生效的;如果没有,就说明解析是不生效的。
- python中file对象的常用方法