This commit is contained in:
shoopea 2019-05-10 18:21:02 +08:00
parent 9748e83b93
commit 6d93169aee

View File

@ -143,6 +143,9 @@ func SQLJobWorker(id int) {
for true {
jobs, err := loadCurrentJobs()
logOnError(err, "SQLJobWorker["+strconv.Itoa(id)+"] : loadCurrentJobs")
if len(jobs) > 0 {
log.Printf("SQLJobWorker["+strconv.Itoa(id)+"] : %d jobs.\n", len(jobs))
}
if len(jobs) < SQLJobSliceSize {
time.Sleep(100 * time.Millisecond)
}