This commit is contained in:
shoopea 2019-05-10 17:27:55 +08:00
parent a2ccadb2d4
commit 6b6b33e078

View File

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