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.") }