diff --git a/workers.go b/workers.go index e4d82b8..42c6660 100644 --- a/workers.go +++ b/workers.go @@ -617,7 +617,7 @@ func SQLJobWorker() { JobQueue <- j } if len(jobs) < SQLJobSliceSize { - time.Sleep(100 * time.Millisecond) + //time.Sleep(100 * time.Millisecond) } } else { time.Sleep(1 * time.Second) @@ -630,7 +630,6 @@ func JobWorker(id int, jobs <-chan Job) { //log.Printf("jobWorker[" + strconv.Itoa(id) + "] : Starting.") // FIXME : discard timed out jobs for j := range jobs { - log.Printf("JobWorker[%d] : Starting job %d (timeout : %s).\n", id, j.ID64, j.Timeout.Format(time.RFC3339)) if time.Now().UTC().Before(j.Timeout) { switch j.JobTypeID64 { case cacheObjSubType[`job_rescan_msg`]: