Method ExecuteAsync

pkg/tools/builtin/task_executor.go:130–195

ExecuteAsync 异步执行任务

(ctx context.Context, agentType, prompt string, opts *TaskExecuteOptions)

// ExecuteAsync 异步执行任务
func (te *TaskExecutor) ExecuteAsync(ctx context.Context, agentType, prompt string, opts *TaskExecuteOptions) (*TaskExecutionHandle, error) {
	te.mu.RLock()
	factory := te.executorFactory
	te.mu.RUnlock()

	if factory == nil {
		return nil, errors.New("executor factory not configured")
	}

	// 创建执行器
	executor, err := factory.Create(agentType)
	if err != nil {
		return nil, fmt.Errorf("failed to create executor: %w", err)
	}

	taskID := fmt.Sprintf("task_%d", time.Now().UnixNano())
	execCtx, cancel := context.WithCancel(ctx)

	handle := &TaskExecutionHandle{
		TaskID:     taskID,
		AgentType:  agentType,
		Status:     "pending",
		StartTime:  time.Now(),
		CancelFunc: cancel,
	}

	// 异步执行
	go func() {
		handle.Status = "running"

		req := &types.SubAgentRequest{
			AgentType: agentType,
			Task:      prompt,
			Context:   opts.Context,
		}

		if opts.Timeout > 0 {
			req.Timeout = opts.Timeout
		}

		result, err := executor.Execute(execCtx, req)

		now := time.Now()
		handle.EndTime = &now

		if err != nil {
			handle.Status = "failed"
			handle.Result = &types.SubAgentResult{
				AgentType: agentType,
				Success:   false,
				Error:     err.Error(),
				Duration:  time.Since(handle.StartTime),
			}
			return
		}

		handle.Result = result
		if result.Success {