Method Create

pkg/core/pool.go:43–66

Create 创建新 Agent 并加入池

(ctx context.Context, config *types.AgentConfig)

// Create 创建新 Agent 并加入池
func (p *Pool) Create(ctx context.Context, config *types.AgentConfig) (*agent.Agent, error) {
	p.mu.Lock()
	defer p.mu.Unlock()

	// 检查是否已存在
	if _, exists := p.agents[config.AgentID]; exists {
		return nil, fmt.Errorf("agent already exists: %s", config.AgentID)
	}

	// 检查池容量
	if len(p.agents) >= p.maxAgents {
		return nil, fmt.Errorf("pool is full (max %d agents)", p.maxAgents)
	}

	// 创建 Agent
	ag, err := agent.Create(ctx, config, p.deps)
	if err != nil {
		return nil, fmt.Errorf("create agent: %w", err)
	}

	// 加入池
	p.agents[config.AgentID] = ag
	return ag, nil
}

// Get 获取指定 Agent
func (p *Pool) Get(agentID string) (*agent.Agent, bool) {