diff --git a/src/main/java/com/jd/platform/async/executor/timeout/WheelMain.java b/src/main/java/com/jd/platform/async/executor/timeout/WheelMain.java index e37f748..c1792aa 100644 --- a/src/main/java/com/jd/platform/async/executor/timeout/WheelMain.java +++ b/src/main/java/com/jd/platform/async/executor/timeout/WheelMain.java @@ -90,7 +90,7 @@ public class WheelMain { return; } //放到第几个槽 - int putIndex = INDEX.get() + delay % MAX_SIZE - 1; + int putIndex = INDEX.get() + delay % MAX_SIZE - 1 + 20; CopyOnWriteArrayList list = allTaskList.get(putIndex % MAX_SIZE); //添加到该槽位的队列中 list.add(singleTask);