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

fixed #7

This commit is contained in:
andy pan 2018-08-08 18:08:06 +08:00
parent 62fc58f047
commit e99d428a5f
2 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pool.go
View File

@ -55,6 +55,7 @@ type Pool struct {
once sync.Once once sync.Once
} }
// clear expired workers periodically. // clear expired workers periodically.
func (p *Pool) periodicallyPurge() { func (p *Pool) periodicallyPurge() {
heartbeat := time.NewTicker(p.expiryDuration) heartbeat := time.NewTicker(p.expiryDuration)
@ -77,7 +78,11 @@ func (p *Pool) periodicallyPurge() {
} }
n++ n++
if n > 0 { if n > 0 {
p.workers = idleWorkers[n:] if n >= cap(idleWorkers) {
p.workers = idleWorkers[:0]
} else {
p.workers = idleWorkers[n:]
}
} }
p.lock.Unlock() p.lock.Unlock()
} }

6
pool_func.go
View File

@ -79,7 +79,11 @@ func (p *PoolWithFunc) periodicallyPurge() {
} }
n++ n++
if n > 0 { if n > 0 {
p.workers = idleWorkers[n:] if n >= cap(idleWorkers) {
p.workers = idleWorkers[:0]
} else {
p.workers = idleWorkers[n:]
}
} }
p.lock.Unlock() p.lock.Unlock()
} }