设置单个任务超时时间轮

This commit is contained in:
wuweifeng10
2021-11-17 14:54:59 +08:00
parent af82492d4f
commit 7f253591d2

View File

@@ -90,7 +90,7 @@ public class WheelMain {
return;
}
//放到第几个槽
int putIndex = INDEX.get() + delay % MAX_SIZE;
int putIndex = INDEX.get() + delay % MAX_SIZE - 1;
CopyOnWriteArrayList<SingleTask> list = allTaskList.get(putIndex % MAX_SIZE);
//添加到该槽位的队列中
list.add(singleTask);