From dae4131c3f9bae9e26a170d627d66bbc208b37ad Mon Sep 17 00:00:00 2001 From: xtaci Date: Mon, 9 Mar 2020 21:24:19 +0800 Subject: [PATCH] bugfix in timer --- timedsched.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/timedsched.go b/timedsched.go index 3ff8fc7..3f2a580 100644 --- a/timedsched.go +++ b/timedsched.go @@ -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 {