From 05d2ea3ee5773e23519ce8893c5e74e038098444 Mon Sep 17 00:00:00 2001 From: Newnius Date: Mon, 13 Apr 2020 22:37:24 +0800 Subject: [PATCH] bug fix --- src/scheduler_fair.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 8a1f007..3797ffc 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -82,6 +82,9 @@ func (scheduler *SchedulerFair) Start() { }() } else { log.Info("No more jobs to scheduling", time.Now()) + scheduler.schedulingMu.Lock() + scheduler.schedulingJobsCnt-- + scheduler.schedulingMu.Unlock() go func() { scheduler.UpdateNextQueue() }()