diff --git a/worker/worker.go b/worker/worker.go index bd0f1a9..eff7205 100644 --- a/worker/worker.go +++ b/worker/worker.go @@ -291,6 +291,7 @@ func (w *Worker) runSchedule() { w.L.Unlock() + tick := time.Tick(5 * time.Second) for { select { case jobMsg := <-w.managerChan: @@ -326,7 +327,7 @@ func (w *Worker) runSchedule() { w.schedule.AddJob(schedTime, job) } - case <-time.Tick(5 * time.Second): + case <-tick: // check schedule every 5 seconds if job := w.schedule.Pop(); job != nil { job.ctrlChan <- jobStart