From eba07133891d248230d1c7c0d68d2953aa7fd673 Mon Sep 17 00:00:00 2001
From: wuweifeng10 <wuweifeng10@jd.com>
Date: Wed, 17 Nov 2021 15:49:25 +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 87f3960..5e4242a 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
@@ -71,7 +71,7 @@ public class WheelMain {
             //遍历槽内所有任务
             for (SingleTask singleTask : timerTaskList) {
                 //如果level = 0，代表时间到了，或者创建时间+超时时间>当前时间了，也是时间到了
-                if (singleTask.getLevel() <= 0 || singleTask.getCurrentTime() + singleTask.getDelayMs() >= System.currentTimeMillis()) {
+                if (singleTask.getLevel() <= 0 || singleTask.getCurrentTime() + singleTask.getDelayMs() <= System.currentTimeMillis()) {
                     //给予回调
                     singleTask.getTimeoutTask().timeoutCallback();
                     //从列表删除