超时时间轮

2026-03-22 04:27:15 +08:00 · 2021-11-15 10:57:23 +08:00
parent d8d9c2d3d6
commit 6061806f03
1 changed files with 1 additions and 1 deletions
--- a/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java
+++ b/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java
@@ -298,7 +298,7 @@ public class WorkerWrapper<T, V> {
    private void fire() {
        //如果对任务有单独超时设置
        if (delayMs != null) {
-            com.jd.platform.async.executor.wheel.TimerTask timerTask = new TimerTask(delayMs, new TimeOutCheckMession(this));
+            TimerTask timerTask = new TimerTask(delayMs, new TimeOutCheckMession(this));
            Async.getTimer().addTask(timerTask);
        }