exit faster in cleanup thread

2024-02-27 03:18:06 +00:00 · 2016-01-10 10:31:27 +01:00
parent add1197cc9
commit 4773a8f4ae
1 changed files with 2 additions and 0 deletions
@@ -90,6 +90,8 @@ func (queue *TimedQueue) cleanup(tick <-chan time.Time) {
 				queue.queue.Swap(i, queue.queue.Len()-1)
 				queue.queue.Pop()
 				changed = true
+			} else {
+				break
 			}
 		}
 		if changed {