From d8e24a0ba1fcda146d2c06934e69080d10e6481b Mon Sep 17 00:00:00 2001 From: Newnius Date: Sun, 3 May 2020 11:29:49 +0800 Subject: [PATCH] update --- src/scheduler_fair.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 56ae0c3..6daa26d 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -162,11 +162,11 @@ func (scheduler *SchedulerFair) Start() { scheduler.schedulingMu.Lock() scheduler.schedulingJobsCnt-- scheduler.schedulingMu.Unlock() - go func() { - scheduler.UpdateNextQueue() - }() } scheduler.queueMu.Unlock() + go func() { + scheduler.UpdateNextQueue() + }() } }() @@ -180,6 +180,7 @@ func (scheduler *SchedulerFair) Start() { continue } log.Info(scheduler.queueUsingGPU) + log.Info(scheduler.queuesSchedulingCnt) scheduler.queuesUsingGPUMu.Lock() if cnt, ok := scheduler.queuesSchedulingCnt[t[0].Group]; ok && cnt > 0 { scheduler.queuesUsingGPUMu.Unlock()