diff --git a/scheduler/scheduler.go b/scheduler/scheduler.go index a25efc7f5..77d6ff077 100644 --- a/scheduler/scheduler.go +++ b/scheduler/scheduler.go @@ -42,6 +42,7 @@ func (s *Scheduler) Loop() { for { s.Lock() for len(s.queue) == 0 { //hang here if empty + s.Unlock() <-s.restartLoop } a0 := s.queue[0]