mirror
/
ants
mirror of https://github.com/panjf2000/ants.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'develop'

This commit is contained in:
Andy Pan 2018-08-08 21:44:44 +08:00
parent 1b77c3ece5 e51be35d84
commit 666635c65d
2 changed files with 8 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pool.go
View File

@ -77,13 +77,11 @@ func (p *Pool) periodicallyPurge() {
idleWorkers[i] = nil idleWorkers[i] = nil
} }
n++ n++
if n > 0 {
if n >= len(idleWorkers) { if n >= len(idleWorkers) {
p.workers = idleWorkers[:0] p.workers = idleWorkers[:0]
} else { } else {
p.workers = idleWorkers[n:] p.workers = idleWorkers[n:]
} }
}
p.lock.Unlock() p.lock.Unlock()
} }
} }

2
pool_func.go
View File

@ -78,13 +78,11 @@ func (p *PoolWithFunc) periodicallyPurge() {
idleWorkers[i] = nil idleWorkers[i] = nil
} }
n++ n++
if n > 0 {
if n >= len(idleWorkers) { if n >= len(idleWorkers) {
p.workers = idleWorkers[:0] p.workers = idleWorkers[:0]
} else { } else {
p.workers = idleWorkers[n:] p.workers = idleWorkers[n:]
} }
}
p.lock.Unlock() p.lock.Unlock()
} }
} }