Merge pull request #6471 from seakider/fix_queuetransfertask

Fixed - RDelayedQueue cannot get anything when server run a long time
pull/6474/head
Nikita Koksharov 1 week ago committed by GitHub
commit bf5fb90872
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

@ -133,9 +133,8 @@ public abstract class QueueTransferTask {
} }
} }
}, delay, TimeUnit.MILLISECONDS); }, delay, TimeUnit.MILLISECONDS);
if (!lastTimeout.compareAndSet(oldTimeout, new TimeoutTask(startTime, timeout))) {
timeout.cancel(); lastTimeout.compareAndSet(oldTimeout, new TimeoutTask(startTime, timeout));
}
} else { } else {
pushTask(); pushTask();
} }

Loading…
Cancel
Save