diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 065217e..fe6815e 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -58,7 +58,7 @@ func (scheduler *SchedulerFair) Start() { continue } scheduler.schedulingMu.Lock() - if scheduler.schedulingJobsCnt >= pool.poolsCount { + if scheduler.schedulingJobsCnt >= pool.poolsCount/10 { scheduler.schedulingMu.Unlock() continue }