From 613d46e4e39521f838e8308ea0296612756f7947 Mon Sep 17 00:00:00 2001 From: bigeagle Date: Wed, 15 Jun 2016 00:31:53 +0800 Subject: [PATCH] fix(worker): fix resource leakage caused by time.Tick(), closing #33 --- worker/worker.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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