Redisson 分布式锁源码 03:可重入锁互斥

2021-07-09 15:59:13 浏览数 (1)

前言

看过可重入锁的 Lua 脚本,已经可以知道当锁存在时,是会加锁失败的。

下面看一下,加锁失败之后是如何处理的呢?

1

加锁 Lua 脚本

在 lua 脚本中,前两段 if 分别排除了两种情况:

  1. 锁不存在;
  2. 锁存在且是自己线程(可重入);

剩下的情况就是锁存在,但是不是自己,也就意味着加锁失败。

执行 pttl 命令,返回锁的剩余时间。

2

加锁失败后的处理

源码定位:org.redisson.RedissonLock#lock(long, java.util.concurrent.TimeUnit, boolean)

先来看开头一部分:

加锁成功后,会返回 ttl,此处会判断为 null,直接返回。

所以,下面的部分就是当获取锁失败之后的逻辑。

忽略掉不需要很关注的逻辑,重点则是 while (true) 里面这一小块。

一直循环调用 tryAcquire 方法,直到加锁成功!

3

总结

  1. 可重入锁的互斥是依靠 Redis Lua 脚本来保证的;
  2. 加锁失败会返回当前锁的剩余时间;
  3. 加锁失败后,会在 Java 代码中使用 while 循环一直尝试加锁。

大概的流程,如下图:

- <End /> -

0 人点赞