From 6b6b33e07856e3be4f07e7ab3b37d405a8ebaa1d Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 10 May 2019 17:27:55 +0800 Subject: [PATCH] test --- workers.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/workers.go b/workers.go index 7063bea..b344a96 100644 --- a/workers.go +++ b/workers.go @@ -143,7 +143,9 @@ func SQLJobWorker(id int) { for true { jobs, err := loadCurrentJobs() logOnError(err, "SQLJobWorker["+strconv.Itoa(id)+"] : loadCurrentJobs") - time.Sleep(100 * time.Millisecond) + if len(jobs) < SQLJobSliceSize { + time.Sleep(100 * time.Millisecond) + } } log.Printf("SQLJobWorker[" + strconv.Itoa(id) + "] : Closing.") }