diff --git a/min_heap.go b/min_heap.go index 5f79ff3..ce046e4 100644 --- a/min_heap.go +++ b/min_heap.go @@ -104,7 +104,7 @@ func (m *minHeap) getNewSleepTime() time.Duration { return time.Hour } - timeout := time.Since(m.minHeaps[0].absExpire) + timeout := m.minHeaps[0].absExpire.Sub(time.Now()) if timeout < 0 { timeout = 0 }