go-delayqueue

go-delayqueue copied to clipboard

服务重启延迟队列重新计算

1

写的很好，但是我发现一个问题，服务停止一会然后重启，会从redis拿数据然后重新计算时间，中间的时间误差在代码中没有看到解决

sankforever

type wheel struct { // NotifyTasks []*Task //所有在时间轮上的任务均采用链表形式存储 //如果采用数组，对应已经执行过的任务，会造成不必要的空间浪费或者数组移动造成的时间复杂度 NotifyTasks *Task } 这个做不到无锁吧？如果不加锁的话，多起几个goroutine进行PUSH会有问题

jerk1991