From b7f63a4052a5aed680423b0f4f9ef5669fc9faa5 Mon Sep 17 00:00:00 2001 From: Newnius Date: Sun, 3 May 2020 11:31:45 +0800 Subject: [PATCH] update --- src/scheduler_fair.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 6daa26d..9fa9210 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -107,6 +107,9 @@ func (scheduler *SchedulerFair) Start() { scheduler.queueMu.Lock() queue := scheduler.nextQueue + go func() { + scheduler.UpdateNextQueue() + }() if len(scheduler.queues[queue]) > 0 { jm := JobManager{} jm.job = scheduler.queues[queue][0] @@ -164,9 +167,6 @@ func (scheduler *SchedulerFair) Start() { scheduler.schedulingMu.Unlock() } scheduler.queueMu.Unlock() - go func() { - scheduler.UpdateNextQueue() - }() } }()