From 13016baf8fceba2aac82ba0d0849d9a92d2685e7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B0=8F=E4=B9=8C=E9=BE=9F=E4=B8=8D=E4=BC=9A=E5=86=99?= =?UTF-8?q?=E4=BB=A3=E7=A0=81?= <41791762+coding-tortoise@users.noreply.github.com> Date: Wed, 17 Mar 2021 11:09:35 +0800 Subject: [PATCH] Update RedissonLock.java MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit fixed concurrency problems Signed-off-by: 小乌龟不会写代码 <41791762+coding-tortoise@users.noreply.github.com> --- redisson/src/main/java/org/redisson/RedissonLock.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/redisson/src/main/java/org/redisson/RedissonLock.java b/redisson/src/main/java/org/redisson/RedissonLock.java index bf647a6ff..fcee9e325 100644 --- a/redisson/src/main/java/org/redisson/RedissonLock.java +++ b/redisson/src/main/java/org/redisson/RedissonLock.java @@ -161,8 +161,9 @@ public class RedissonLock extends RedissonBaseLock { if (ttlRemaining) { if (-1 != leaseTime) { internalLockLeaseTime = unit.toMillis(leaseTime); + } else { + scheduleExpirationRenewal(threadId); } - scheduleExpirationRenewal(threadId); } }); return ttlRemainingFuture; @@ -185,8 +186,9 @@ public class RedissonLock extends RedissonBaseLock { if (ttlRemaining == null) { if (-1 != leaseTime) { internalLockLeaseTime = unit.toMillis(leaseTime); + } else { + scheduleExpirationRenewal(threadId); } - scheduleExpirationRenewal(threadId); } }); return ttlRemainingFuture;