记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 276575ff authored by 张国柄's avatar 张国柄
Browse files
Options

fix:redisson;

parent 9f9ca7ad
Show whitespace changes
Inline Side-by-side
Showing with 6 additions and 2 deletions
liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redisson/src/main/java/com/liquidnet/common/cache/redisson/handle/RedisDistributedLocker.java
View file @ 276575ff
...@@ -56,11 +56,15 @@ public class RedisDistributedLocker implements DistributedLocker { ...@@ -56,11 +56,15 @@ public class RedisDistributedLocker implements DistributedLocker {
@Override @Override
public void unlock(String lockKey) { public void unlock(String lockKey) {
RLock lock = redissonClient.getLock(lockKey); RLock lock = redissonClient.getLock(lockKey);
if (lock.isHeldByCurrentThread()) {
lock.unlock(); lock.unlock();
} }
}
@Override @Override
public void unlock(RLock lock) { public void unlock(RLock lock) {
if (lock.isHeldByCurrentThread()) {
lock.unlock(); lock.unlock();
} }
}
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment