From 7f253591d21994da9046174f7659d9a41c67de8a Mon Sep 17 00:00:00 2001 From: wuweifeng10 Date: Wed, 17 Nov 2021 14:54:59 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AE=BE=E7=BD=AE=E5=8D=95=E4=B8=AA=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E8=B6=85=E6=97=B6=E6=97=B6=E9=97=B4=E8=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/jd/platform/async/executor/timeout/WheelMain.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 56e64c5..e37f748 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; + int putIndex = INDEX.get() + delay % MAX_SIZE - 1; CopyOnWriteArrayList list = allTaskList.get(putIndex % MAX_SIZE); //添加到该槽位的队列中 list.add(singleTask);