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

format

This commit is contained in:
AndyPan 2018-09-30 09:40:33 +08:00
parent e238e0fad0
commit e8ccc8ecca
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pool.go
View File

@ -196,10 +196,10 @@ func (p *Pool) getWorker() *Worker {
} }
if waiting { if waiting {
for{ for {
p.cond.Wait() p.cond.Wait()
l := len(p.workers) - 1 l := len(p.workers) - 1
if l < 0{ if l < 0 {
continue continue
} }
w = p.workers[l] w = p.workers[l]

4
pool_func.go
View File

@ -198,10 +198,10 @@ func (p *PoolWithFunc) getWorker() *WorkerWithFunc {
} }
if waiting { if waiting {
for{ for {
p.cond.Wait() p.cond.Wait()
l := len(p.workers) - 1 l := len(p.workers) - 1
if l < 0{ if l < 0 {
continue continue
} }
w = p.workers[l] w = p.workers[l]