fix

guonaihong · guonaihong · commit c35e2416f43c · 2024-05-15T11:32:53.000+08:00
diff --git a/min_heap.go b/min_heap.go
@@ -104,7 +104,7 @@ func (m *minHeap) getNewSleepTime() time.Duration {
 		return time.Hour
 	}
 
-	timeout := m.minHeaps[0].absExpire.Sub(time.Now())
+	timeout := time.Until(m.minHeaps[0].absExpire)
 	if timeout < 0 {
 		timeout = 0
 	}

Original file line number	Diff line number	Diff line change
`@@ -104,7 +104,7 @@ func (m *minHeap) getNewSleepTime() time.Duration {`
`104`	`104`	`return time.Hour`
`105`	`105`	`}`
`106`	`106`
`107`		`- timeout := m.minHeaps[0].absExpire.Sub(time.Now())`
	`107`	`+ timeout := time.Until(m.minHeaps[0].absExpire)`
`108`	`108`	`if timeout < 0 {`
`109`	`109`	`timeout = 0`
`110`	`110`	`}`