设置单个任务超时时间轮

This commit is contained in:
wuweifeng10
2021-11-17 15:20:40 +08:00
parent e71890ff79
commit 01e86d0d11

View File

@@ -89,7 +89,7 @@ public class WheelMain {
if (delay <= 0) {
return;
}
//放到第几个槽
//放到第几个槽因为在add进来时任务就已经开始执行了要减去在添加这一霎那的那1毫秒的槽位
int putIndex = INDEX.get() + delay % MAX_SIZE - 1 + 20;
CopyOnWriteArrayList<SingleTask> list = allTaskList.get(putIndex % MAX_SIZE);
//添加到该槽位的队列中