diff options
Diffstat (limited to 'static_pool.go')
| -rw-r--r-- | static_pool.go | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/static_pool.go b/static_pool.go index b974ac90..95d2fe14 100644 --- a/static_pool.go +++ b/static_pool.go @@ -159,13 +159,15 @@ func (p *StaticPool) Destroy() { wg.Wait() } -// finds free worker in a given time interval or creates new if allowed. +// finds free worker in a given time interval. Skips dead workers. func (p *StaticPool) allocateWorker() (w *Worker, err error) { for i := atomic.LoadInt64(&p.numDead); i >= 0; i++ { - // this loop is required to skip issues with dead workers still being in a ring. + // this loop is required to skip issues with dead workers still being in a ring + // (we know how many workers). select { case w = <-p.free: if w.State().Value() != StateReady { + // found expected dead worker atomic.AddInt64(&p.numDead, ^int64(0)) continue } |