Merge branch 'develop'

This commit is contained in:
andy pan 2018-08-08 17:22:56 +08:00
commit 01cb40f8fb
2 changed files with 2 additions and 2 deletions

View File

@ -75,8 +75,8 @@ func (p *Pool) periodicallyPurge() {
w.task <- nil
idleWorkers[i] = nil
}
n++
if n > 0 {
n++
p.workers = idleWorkers[n:]
}
p.lock.Unlock()

View File

@ -77,8 +77,8 @@ func (p *PoolWithFunc) periodicallyPurge() {
w.args <- nil
idleWorkers[i] = nil
}
n++
if n > 0 {
n++
p.workers = idleWorkers[n:]
}
p.lock.Unlock()