fixing worker allocation loop

1 files changed, 3 insertions, 1 deletions

diff --git a/static_pool.go b/static_pool.go
index 18bfaf60..24665c01 100644
--- a/static_pool.go
+++ b/static_pool.go
@@ -169,13 +169,15 @@ func (p *StaticPool) allocateWorker() (w *Worker, err error) {
 			return nil, fmt.Errorf("worker timeout (%s)", p.cfg.AllocateTimeout)
 		case w = <-p.free:
 			timeout.Stop()
+
 			if w.State().Value() != StateReady {
 				continue
 			}
+			return w, nil
 		}
 	}
 
-	return w, nil
+	return nil, fmt.Errorf("all workers are dead (%v)", p.cfg.NumWorkers)
 }
 
 // release releases or replaces the worker.