Method Shutdown

pkg/core/pool.go:185–199

Shutdown 关闭所有 Agent

()

// Shutdown 关闭所有 Agent
func (p *Pool) Shutdown() error {
	p.mu.Lock()
	defer p.mu.Unlock()

	var lastErr error
	for id, ag := range p.agents {
		if err := ag.Close(); err != nil {
			lastErr = fmt.Errorf("close agent %s: %w", id, err)
		}
	}

	// 清空池
	p.agents = make(map[string]*agent.Agent)
	return lastErr
}

// ForEach 遍历所有 Agent
func (p *Pool) ForEach(fn func(agentID string, ag *agent.Agent) error) error {