Merge branch 'develop'

pool.go

@@ -55,6 +55,7 @@ type Pool struct {
 
 	once sync.Once
 }
+
 // clear expired workers periodically.
 func (p *Pool) periodicallyPurge() {
 	heartbeat := time.NewTicker(p.expiryDuration)
@@ -77,8 +78,12 @@ func (p *Pool) periodicallyPurge() {
 		}
 		n++
 		if n > 0 {
+			if n >= cap(idleWorkers) {
+				p.workers = idleWorkers[:0]
+			} else {
 				p.workers = idleWorkers[n:]
 			}
+		}
 		p.lock.Unlock()
 	}
 }

pool_func.go

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