Method ExecuteAsync

pkg/agent/subagent.go:310–440

ExecuteAsync 异步执行子 Agent 任务

(ctx context.Context, req *types.SubAgentRequest)

// ExecuteAsync 异步执行子 Agent 任务
func (m *SubAgentManager) ExecuteAsync(ctx context.Context, req *types.SubAgentRequest) (string, <-chan *types.SubAgentProgressEvent, error) {
	// 获取规格
	spec, err := m.GetSpec(req.AgentType)
	if err != nil {
		return "", nil, err
	}

	// 生成任务 ID
	taskID := uuid.New().String()

	// 设置超时
	timeout := spec.Timeout
	if req.Timeout > 0 {
		timeout = req.Timeout
	}
	if timeout == 0 {
		timeout = m.defaultTimeout
	}

	execCtx, cancel := context.WithTimeout(context.Background(), timeout)

	// 创建进度通道
	progressChan := make(chan *types.SubAgentProgressEvent, 100)

	// 创建句柄
	handle := &SubAgentHandle{
		ID:            taskID,
		AgentType:     req.AgentType,
		Request:       req,
		StartTime:     time.Now(),
		Status:        "starting",
		CancelFunc:    cancel,
		ProgressChan:  progressChan,
		ParentAgentID: req.ParentAgentID,
	}
	m.registerHandle(handle)

	// 异步执行
	go func() {
		defer close(progressChan)
		defer cancel()
		defer m.unregisterHandle(taskID)

		// 发送开始事件
		progressChan <- &types.SubAgentProgressEvent{
			AgentType: req.AgentType,
			TaskID:    taskID,
			Phase:     "started",
			Progress:  0,
			Message:   "Subagent starting...",
		}

		// 创建子 Agent
		agentConfig := m.buildAgentConfig(spec, req, taskID)
		agent, err := Create(execCtx, agentConfig, m.deps)
		if err != nil {
			handle.Status = "failed"
			handle.Result = &types.SubAgentResult{