mirror of
https://github.com/newnius/YAO-scheduler.git
synced 2025-06-08 06:41:56 +00:00
bug fix
This commit is contained in:
parent
7e1c4349b9
commit
05d2ea3ee5
@ -82,6 +82,9 @@ func (scheduler *SchedulerFair) Start() {
|
|||||||
}()
|
}()
|
||||||
} else {
|
} else {
|
||||||
log.Info("No more jobs to scheduling", time.Now())
|
log.Info("No more jobs to scheduling", time.Now())
|
||||||
|
scheduler.schedulingMu.Lock()
|
||||||
|
scheduler.schedulingJobsCnt--
|
||||||
|
scheduler.schedulingMu.Unlock()
|
||||||
go func() {
|
go func() {
|
||||||
scheduler.UpdateNextQueue()
|
scheduler.UpdateNextQueue()
|
||||||
}()
|
}()
|
||||||
|
Loading…
Reference in New Issue
Block a user