redisson 基于 org.redisson:redisson-spring-data-27:3.27.2 版本
在 java 中，操作 redis 一般都会选择 redisson 框架, 我们需要了解常用功能的实现原理, 这次来介绍 RedissonSpinLock。
使用方式
1
2
3
4
5
6
7
8
9
10
11
| @Test
void testSpinLock() {
RLock lock = redissonClient.getSpinLock("lock");
try {
lock.lock();
ThreadUtil.sleep(30, TimeUnit.SECONDS);
System.out.println("xxx");
} finally {
lock.unlock();
}
}
|
lock
源码位置: org.redisson.RedissonSpinLock#lock
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
| @Override
public void lock() {
try {
lockInterruptibly(-1, null);
} catch (InterruptedException e) {
throw new IllegalStateException();
}
}
@Override
public void lockInterruptibly(long leaseTime, TimeUnit unit) throws InterruptedException {
long threadId = Thread.currentThread().getId();
// 尝试获取锁, 和 RedissonLock 逻辑一样，不解析了
Long ttl = tryAcquire(leaseTime, unit, threadId);
// lock acquired
if (ttl == null) {
return;
}
// 使用指数级睡眠策略
LockOptions.BackOffPolicy backOffPolicy = backOff.create();
while (ttl != null) {
long nextSleepPeriod = backOffPolicy.getNextSleepPeriod();
// 睡眠一段时间
Thread.sleep(nextSleepPeriod);
// 然后再尝试获取锁
ttl = tryAcquire(leaseTime, unit, threadId);
}
}
|
unlock
RedissonSpinLock 和 RedissonLock 的解锁代码是一样的，所以就不解析了。