re
/
ants
forked from mirror/ants
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix a bug from the previous commit 

Updates #141
This commit is contained in:
Andy Pan 2021-03-19 01:21:14 +08:00
parent 36c4272286
commit e01348e424
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pool.go
View File

@ -244,8 +244,8 @@ func (p *Pool) retrieveWorker() (w *goWorker) {
p.cond.Wait() p.cond.Wait()
p.blockingNum-- p.blockingNum--
if p.Running() == 0 { if p.Running() == 0 {
p.lock.Unlock()
if !p.IsClosed() { if !p.IsClosed() {
p.lock.Unlock()
spawnWorker() spawnWorker()
} }
return return

2
pool_func.go
View File

@ -262,8 +262,8 @@ func (p *PoolWithFunc) retrieveWorker() (w *goWorkerWithFunc) {
p.cond.Wait() p.cond.Wait()
p.blockingNum-- p.blockingNum--
if p.Running() == 0 { if p.Running() == 0 {
p.lock.Unlock()
if !p.IsClosed() { if !p.IsClosed() {
p.lock.Unlock()
spawnWorker() spawnWorker()
} }
return return