🦅 Fix a bug when using sync.Pool

2019-01-27 05:09:39 +08:00 · 2019-01-27 05:09:39 +08:00 · 91377c898b
parent 822158c59c
commit 91377c898b
2 changed files with 2 additions and 2 deletions
--- a/pool.go
+++ b/pool.go
@ -207,8 +207,8 @@ func (p *Pool) retrieveWorker() *Worker {
 				pool: p,
 				task: make(chan f, workerChanCap),
 			}
-			w.run()
 		}
+		w.run()
 	} else {
 		for {
 			p.cond.Wait()
--- a/pool_func.go
+++ b/pool_func.go
@ -211,8 +211,8 @@ func (p *PoolWithFunc) retrieveWorker() *WorkerWithFunc {
 				pool: p,
 				args: make(chan interface{}, workerChanCap),
 			}
-			w.run()
 		}
+		w.run()
 	} else {
 		for {
 			p.cond.Wait()