From 490a6b3928738611cde9c6d04f5a182f97b266e5 Mon Sep 17 00:00:00 2001 From: Newnius Date: Mon, 13 Apr 2020 23:41:01 +0800 Subject: [PATCH] update --- src/scheduler_fair.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index fe6815e..4e00e4d 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -53,13 +53,14 @@ func (scheduler *SchedulerFair) Start() { go func() { for { log.Debug("Scheduling") - time.Sleep(time.Millisecond * 100) if !scheduler.enabled { + time.Sleep(time.Millisecond * 100) continue } scheduler.schedulingMu.Lock() if scheduler.schedulingJobsCnt >= pool.poolsCount/10 { scheduler.schedulingMu.Unlock() + time.Sleep(time.Millisecond * 100) continue } scheduler.schedulingJobsCnt++ @@ -85,6 +86,7 @@ func (scheduler *SchedulerFair) Start() { scheduler.schedulingMu.Lock() scheduler.schedulingJobsCnt-- scheduler.schedulingMu.Unlock() + time.Sleep(time.Millisecond * 100) go func() { scheduler.UpdateNextQueue() }()