diff --git a/executor.go b/executor.go index be4def11a..69bdbf15d 100644 --- a/executor.go +++ b/executor.go @@ -162,8 +162,8 @@ func newExecutor(opts ...executorOption) *executor { // somehow between our test above and now the work // queue FILLED UP and we stoically accept this } + idle = 0 } - idle = 0 return } next := atomic.LoadUint64(&e.workCounter)