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

Merge branch 'master' into develop

This commit is contained in:
Andy Pan 2018-10-02 22:39:31 +08:00
parent 90d04008dd 29730bb703
commit 418888be9d
2 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pool.go
View File

@ -146,10 +146,8 @@ func (p *Pool) ReSize(size int) {
}
atomic.StoreInt32(&p.capacity, int32(size))
diff := p.Running() - size
if diff > 0 {
for i := 0; i < diff; i++ {
p.getWorker().task <- nil
}
for i := 0; i < diff; i++ {
p.getWorker().task <- nil
}
}

6
pool_func.go
View File

@ -148,10 +148,8 @@ func (p *PoolWithFunc) ReSize(size int) {
}
atomic.StoreInt32(&p.capacity, int32(size))
diff := p.Running() - size
if diff > 0 {
for i := 0; i < diff; i++ {
p.getWorker().args <- nil
}
for i := 0; i < diff; i++ {
p.getWorker().args <- nil
}
}