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

🙄 Improvement in `periodicallyPurge`

This commit is contained in:
Andy Pan 2019-04-14 11:29:25 +08:00
parent 00294fd50b
commit d6076c09aa
2 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pool.go
View File

@ -69,13 +69,12 @@ func (p *Pool) periodicallyPurge() {
defer heartbeat.Stop() defer heartbeat.Stop()
for range heartbeat.C { for range heartbeat.C {
if CLOSED == atomic.LoadInt32(&p.release) {
break
}
currentTime := time.Now() currentTime := time.Now()
p.lock.Lock() p.lock.Lock()
idleWorkers := p.workers idleWorkers := p.workers
if CLOSED == atomic.LoadInt32(&p.release) {
p.lock.Unlock()
return
}
n := -1 n := -1
for i, w := range idleWorkers { for i, w := range idleWorkers {
if currentTime.Sub(w.recycleTime) <= p.expiryDuration { if currentTime.Sub(w.recycleTime) <= p.expiryDuration {

7
pool_func.go
View File

@ -72,13 +72,12 @@ func (p *PoolWithFunc) periodicallyPurge() {
defer heartbeat.Stop() defer heartbeat.Stop()
for range heartbeat.C { for range heartbeat.C {
if CLOSED == atomic.LoadInt32(&p.release) {
break
}
currentTime := time.Now() currentTime := time.Now()
p.lock.Lock() p.lock.Lock()
idleWorkers := p.workers idleWorkers := p.workers
if CLOSED == atomic.LoadInt32(&p.release) {
p.lock.Unlock()
return
}
n := -1 n := -1
for i, w := range idleWorkers { for i, w := range idleWorkers {
if currentTime.Sub(w.recycleTime) <= p.expiryDuration { if currentTime.Sub(w.recycleTime) <= p.expiryDuration {