调整延迟队列的代码注释

This commit is contained in:
fantasticbin 2024-12-03 10:13:05 +08:00
parent ed4289d224
commit 94c82b2df0

View File

@ -18,7 +18,7 @@ func (q *DelayLkQueue[T]) ContinuousDequeue(notify ...chan T) {
for {
value, ok := q.Dequeue()
if !ok {
time.Sleep(time.Millisecond) // 自旋
time.Sleep(time.Millisecond) // 队列为空休眠1毫秒
continue
}
for _, n := range notify {