设置单个任务超时时间轮

This commit is contained in:
wuweifeng10
2021-11-17 15:49:25 +08:00
parent 72126d74b6
commit eba0713389

View File

@@ -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();
//从列表删除