Redisson 分布式锁源码 03:可重入锁互斥
前言
看过可重入锁的 Lua 脚本,已经可以知道当锁存在时,是会加锁失败的。
下面看一下,加锁失败之后是如何处理的呢?
加锁 Lua 脚本
在 lua 脚本中,前两段 if 分别排除了两种情况:
锁不存在;
锁存在且是自己线程(可重入);
剩下的情况就是锁存在,但是不是自己,也就意味着加锁失败。
执行 pttl
命令,返回锁的剩余时间。
加锁失败后的处理
源码定位:org.redisson.RedissonLock#lock(long, java.util.concurrent.TimeUnit, boolean)
先来看开头一部分:
加锁成功后,会返回 ttl,此处会判断为 null,直接返回。
所以,下面的部分就是当获取锁失败之后的逻辑。
忽略掉不需要很关注的逻辑,重点则是 while (true)
里面这一小块。
一直循环调用 tryAcquire 方法,直到加锁成功!
总结
可重入锁的互斥是依靠 Redis Lua 脚本来保证的;
加锁失败会返回当前锁的剩余时间;
加锁失败后,会在 Java 代码中使用 while 循环一直尝试加锁。
大概的流程,如下图:
相关推荐
版权声明: 本文为 InfoQ 作者【程序员小航】的原创文章。
原文链接:【http://xie.infoq.cn/article/4cd0dae941c80a13b3bfd0a28】。
本文遵守【CC-BY 4.0】协议,转载请保留原文出处及本版权声明。
评论