add one more check when getting worker

2018-05-22 16:10:29 +08:00 · 2018-05-22 16:10:29 +08:00 · f4a3fc5efd
parent 967b0b04e2
commit f4a3fc5efd
1 changed files with 1 additions and 1 deletions
--- a/pool.go
+++ b/pool.go
@ -172,7 +172,7 @@ func (p *Pool) getWorker() *Worker {
 			p.lock.Unlock()
 			break
 		}
-	} else {
+	} else if w == nil {
 		wp := p.workerPool.Get()
 		if wp == nil {
 			w = &Worker{