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()
 				}()