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

update

This commit is contained in:
Andy Pan 2018-07-06 20:20:18 +08:00
parent afba560448
commit 339aaa4475
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pool.go
View File

@ -76,9 +76,10 @@ func (p *Pool) monitorAndClear() {
n = i n = i
w.stop() w.stop()
idleWorkers[i] = nil idleWorkers[i] = nil
p.running--
} }
if n > 0 { if n > 0 {
n += 1 n++
p.workers = idleWorkers[n:] p.workers = idleWorkers[n:]
} }
p.lock.Unlock() p.lock.Unlock()

1
pool_func.go
View File

@ -77,6 +77,7 @@ func (p *PoolWithFunc) MonitorAndClear() {
n = i n = i
w.stop() w.stop()
idleWorkers[i] = nil idleWorkers[i] = nil
p.running--
} }
if n > 0 { if n > 0 {
n += 1 n += 1