Method StartTask

pkg/tools/builtin/task_manager.go:107–202

StartTask 启动后台任务

(ctx context.Context, cmd string, opts *TaskOptions)

// StartTask 启动后台任务
func (tm *FileTaskManager) StartTask(ctx context.Context, cmd string, opts *TaskOptions) (*TaskInfo, error) {
	tm.mu.Lock()
	defer tm.mu.Unlock()

	// 生成任务ID
	taskID := fmt.Sprintf("task_%d", time.Now().UnixNano())

	// 设置默认选项
	if opts == nil {
		opts = &TaskOptions{
			Timeout:       30 * time.Minute,
			Background:    true,
			Shell:         "bash",
			CaptureOutput: true,
			OutputDir:     tm.outputDir,
		}
	}

	if opts.OutputDir == "" {
		opts.OutputDir = tm.outputDir
	}

	// 创建任务信息
	taskInfo := &TaskInfo{
		ID:         taskID,
		Command:    cmd,
		Status:     "starting",
		StartTime:  time.Now(),
		WorkDir:    opts.WorkDir,
		Shell:      opts.Shell,
		Options:    opts,
		Metadata:   make(map[string]string),
		LastUpdate: time.Now(),
	}

	// 构建命令
	fullCmd := tm.buildCommand(cmd, opts)

	// 启动命令
	cmdObj := exec.CommandContext(ctx, "bash", "-c", fullCmd)
	cmdObj.Dir = opts.WorkDir

	// 设置环境变量
	if len(opts.Env) > 0 {
		env := os.Environ()
		for k, v := range opts.Env {
			env = append(env, fmt.Sprintf("%s=%s", k, v))
		}
		cmdObj.Env = env
	}

	// 创建输出文件
	outputFile := filepath.Join(opts.OutputDir, taskID+".stdout")
	errorFile := filepath.Join(opts.OutputDir, taskID+".stderr")

	if opts.CaptureOutput {
		outFile, err := os.Create(outputFile)
		if err != nil {