From e8198d61319bd34be45bf22ab0f822647e1bf628 Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 30 Apr 2020 14:34:06 +0800 Subject: [PATCH] update --- src/scheduler_fair.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index e17a794..d53397a 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -287,9 +287,10 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task) NodeStatus { } } - for i, lock := range locks { + for i, _ := range locks { log.Info("unlock ", i) - lock.Unlock() + //lock.Unlock() + pool.poolsMu[i].Unlock() } go func(res NodeStatus) { if len(res.Status) == 0 {