Fixed - RDelayedQueue cannot get anything when server run a long time

Signed-off-by: seakider <seakider@gmail.com>
pull/6471/head
seakider 1 week ago
parent a2a4f48c69
commit 509646b070

@ -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();
}

Loading…
Cancel
Save