This commit is contained in:
andy pan 2018-05-22 16:20:01 +08:00
parent f4a3fc5efd
commit b2ab15fa96
1 changed files with 1 additions and 1 deletions

View File

@ -173,7 +173,7 @@ func (p *PoolWithFunc) getWorker() *WorkerWithFunc {
p.lock.Unlock() p.lock.Unlock()
break break
} }
} else { } else if w == nil {
wp := p.workerPool.Get() wp := p.workerPool.Get()
if wp == nil { if wp == nil {
w = &WorkerWithFunc{ w = &WorkerWithFunc{