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:58:01 +08:00
parent b7c241d8ac 50918eb4a9
commit 1b77c3ece5
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

@ -78,7 +78,7 @@ func (p *Pool) periodicallyPurge() {
} }
n++ n++
if n > 0 { if n > 0 {
if n >= cap(idleWorkers) { if n >= len(idleWorkers) {
p.workers = idleWorkers[:0] p.workers = idleWorkers[:0]
} else { } else {
p.workers = idleWorkers[n:] p.workers = idleWorkers[n:]

2
pool_func.go
View File

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