Merge pull request #69 from mcarmonaa/fix/lock-on-wait

*: do not lock on worker pool wait and wait backoff on error for scheduling

Author: mcarmonaa

scheduler.go

@@ -91,18 +91,19 @@ func (s *jobScheduler) Schedule() {
 						continue
 					}
 
-					select {
-					case <-s.cancel:
-						return
-					case <-time.After(s.backoff.Duration()):
-					}
 				}
 
 				if ErrJobSource.Is(err) {
 					close(s.jobs)
 					return
 				}
 
+				select {
+				case <-s.cancel:
+					return
+				case <-time.After(s.backoff.Duration()):
+				}
+
 				continue
 			}
 

worker_pool.go

@@ -106,12 +106,8 @@ func (wp *WorkerPool) remove(n int) {
 	wg.Wait()
 }
 
-// Wait waits for the workers to finish. A worker will finish when the queue to
-// retrieve jobs from is closed.
+// Wait waits for the workers to finish.
 func (wp *WorkerPool) Wait() {
-	<-wp.resize
-	defer func() { wp.resize <- struct{}{} }()
-
 	wp.wg.Wait()
 	wp.workers = nil
 	wp.opts.Metrics.Stop(false)