diff --git a/timedsched.go b/timedsched.go index 3f2a580..e20fc52 100644 --- a/timedsched.go +++ b/timedsched.go @@ -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 {