From 0751608eb2a447656a2b6161ced9c6f3e6504fd4 Mon Sep 17 00:00:00 2001 From: Newnius Date: Sun, 3 May 2020 11:06:53 +0800 Subject: [PATCH] update --- src/scheduler_fair.go | 3 --- 1 file changed, 3 deletions(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 4417c74..e2a75c5 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -176,12 +176,10 @@ func (scheduler *SchedulerFair) Start() { scheduler.queueMu.Lock() for q, t := range scheduler.queues { if len(t) == 0 || !InstanceOfGroupManager().groups[t[0].Group].Reserved { - scheduler.queueMu.Unlock() continue } scheduler.queuesUsingGPUMu.Lock() if cnt, ok := scheduler.queuesSchedulingCnt[t[0].Group]; ok && cnt > 0 { - scheduler.queueMu.Unlock() scheduler.queuesUsingGPUMu.Unlock() continue } @@ -199,7 +197,6 @@ func (scheduler *SchedulerFair) Start() { scheduler.queuesUsingGPUMu.Unlock() if pool.TotalGPU-scheduler.UsingGPU-scheduler.allocatingGPU*13/10 < 0 { - scheduler.queueMu.Unlock() continue }