Method StartAsync

pkg/tools/long_running.go:98–160

StartAsync 异步启动工具

(
	ctx context.Context,
	tool Tool,
	args map[string]any,
)

// StartAsync 异步启动工具
func (e *LongRunningExecutor) StartAsync(
	ctx context.Context,
	tool Tool,
	args map[string]any,
) (string, error) {
	// 1. 生成任务 ID
	taskID := generateTaskID()

	// 2. 创建任务状态
	status := &TaskStatus{
		TaskID:    taskID,
		State:     TaskStatePending,
		Progress:  0.0,
		StartTime: time.Now(),
		Metadata:  make(map[string]any),
	}
	e.tasks.Store(taskID, status)

	// 3. 创建可取消的 context
	taskCtx, cancel := context.WithCancel(ctx)
	e.cancels.Store(taskID, cancel)

	// 4. 异步执行
	go func() {
		defer cancel()

		// 更新状态为 Running
		_ = e.updateState(taskID, TaskStateRunning)

		// 执行工具（传递 nil ToolContext，因为 long-running 工具不需要它）
		result, err := tool.Execute(taskCtx, args, nil)

		// 更新最终状态
		now := time.Now()
		if err != nil {
			if taskCtx.Err() == context.Canceled {
				_ = e.updateStatus(taskID, func(s *TaskStatus) {
					s.State = TaskStateCancelled
					s.Error = errors.New("task canceled")
					s.EndTime = &now
				})
			} else {
				_ = e.updateStatus(taskID, func(s *TaskStatus) {
					s.State = TaskStateFailed
					s.Error = err
					s.EndTime = &now
				})
			}
		} else {
			_ = e.updateStatus(taskID, func(s *TaskStatus) {
				s.State = TaskStateCompleted
				s.Progress = 1.0
				s.Result = result
				s.EndTime = &now
			})
		}

		// 清理取消函数