diff --git a/redisson/src/main/java/org/redisson/QueueTransferTask.java b/redisson/src/main/java/org/redisson/QueueTransferTask.java index 2dd7e5df2..de3a41eae 100644 --- a/redisson/src/main/java/org/redisson/QueueTransferTask.java +++ b/redisson/src/main/java/org/redisson/QueueTransferTask.java @@ -133,9 +133,8 @@ public abstract class QueueTransferTask { } } }, delay, TimeUnit.MILLISECONDS); - if (!lastTimeout.compareAndSet(oldTimeout, new TimeoutTask(startTime, timeout))) { - timeout.cancel(); - } + + lastTimeout.compareAndSet(oldTimeout, new TimeoutTask(startTime, timeout)); } else { pushTask(); }