Method cleanExpired

script/pool.go:176–198

()

}

func (p *VMPool) cleanExpired() {
	now := time.Now()
	p.mu.Lock()
	removeCount := 0
	for removeCount < len(p.idle)-p.config.MinIdle &&
		now.Sub(p.idle[removeCount].returnedAt) >= p.config.IdleTime {
		removeCount++
	}
	if removeCount == 0 {
		p.mu.Unlock()
		return
	}
	expired := append([]idleVM(nil), p.idle[:removeCount]...)
	copy(p.idle, p.idle[removeCount:])
	p.idle = p.idle[:len(p.idle)-removeCount]
	p.total -= removeCount
	p.signalLocked()
	p.mu.Unlock()

	for _, item := range expired {
		_ = item.vm.Dispose()
	}
}

func (p *VMPool) signalLocked() {
	close(p.changed)