optimize on timedsched

This commit is contained in:
xtaci
2020-03-22 21:47:17 +08:00
parent bb1f2af922
commit 6f9c25ae24
+1 -2
View File
@@ -74,9 +74,8 @@ func (ts *TimedSched) sched() {
// reset timer to trigger based on the top element
timer.Reset(tasks[0].ts.Sub(now))
}
case <-timer.C:
case now := <-timer.C:
for tasks.Len() > 0 {
now := time.Now()
if now.After(tasks[0].ts) {
heap.Pop(&tasks).(timedFunc).execute()
} else {