Redisson 分布式锁源码 03:可重入锁互斥
前言
看过可重入锁的 Lua 脚本,已经可以知道当锁存在时,是会加锁失败的。
下面看一下,加锁失败之后是如何处理的呢?
1
加锁 Lua 脚本
![](https://filescdn.proginn.com/2c861831f27b3442cc6a2e08b2995e39/d6ca87d57ab405c5fb04608f3231c878.webp)
在 lua 脚本中,前两段 if 分别排除了两种情况:
锁不存在; 锁存在且是自己线程(可重入);
剩下的情况就是锁存在,但是不是自己,也就意味着加锁失败。
执行 pttl
命令,返回锁的剩余时间。
2
加锁失败后的处理
源码定位:org.redisson.RedissonLock#lock(long, java.util.concurrent.TimeUnit, boolean)
![](https://filescdn.proginn.com/a544b02309d03117f560b214e945ec17/5fcba5a0c7f172184fe0023a670a2584.webp)
先来看开头一部分:
加锁成功后,会返回 ttl,此处会判断为 null,直接返回。
所以,下面的部分就是当获取锁失败之后的逻辑。
![](https://filescdn.proginn.com/cf054739530385446fb729db7805b910/e7c6107ce8124dc868eb5377b38a4715.webp)
忽略掉不需要很关注的逻辑,重点则是 while (true)
里面这一小块。
一直循环调用 tryAcquire 方法,直到加锁成功!
3
总结
可重入锁的互斥是依靠 Redis Lua 脚本来保证的; 加锁失败会返回当前锁的剩余时间; 加锁失败后,会在 Java 代码中使用 while 循环一直尝试加锁。
大概的流程,如下图:
![](https://filescdn.proginn.com/6d3b8414700cfed77c94c0ce4c077818/b76daf782ffd3a3dc305ec2cf81fde67.webp)
- <End /> -
历史文章 | 相关推荐
评论