bugfix in timer

2024-04-21 12:32:15 +00:00 · 2020-03-09 21:24:19 +08:00
parent 2ea2218ef0
commit dae4131c3f
1 changed files with 2 additions and 4 deletions
@@ -71,10 +71,8 @@ func (ts *TimedSched) sched() {
 				task.execute()
 			} else {
 				heap.Push(&tasks, task)
-				// activate timer if timer has hibernated due to 0 tasks.
-				if tasks.Len() == 1 {
-					timer.Reset(task.ts.Sub(now))
-				}
+				// reset timer to trigger based on the top element
+				timer.Reset(tasks[0].ts.Sub(now))
 			}
 		case <-timer.C:
 			for tasks.Len() > 0 {