Method monitorTask

pkg/tools/builtin/task_manager.go:381–417

monitorTask 监控任务执行

(ctx context.Context, task *TaskInfo, cmd *exec.Cmd)

// monitorTask 监控任务执行
func (tm *FileTaskManager) monitorTask(ctx context.Context, task *TaskInfo, cmd *exec.Cmd) {
	defer func() {
		// 发送清理信号
		select {
		case tm.cleanupChan <- task.ID:
		default:
		}
	}()

	// 等待命令完成
	err := cmd.Wait()

	tm.mu.Lock()
	defer tm.mu.Unlock()

	// 更新任务状态
	now := time.Now()
	task.EndTime = &now
	task.Duration = now.Sub(task.StartTime)
	task.LastUpdate = now

	if err != nil {
		exitErr := &exec.ExitError{}
		if errors.As(err, &exitErr) {
			task.ExitCode = exitErr.ExitCode()
			task.Status = "failed"
		} else {
			task.Status = "failed"
			task.ExitCode = -1
		}
	} else {
		task.ExitCode = 0
		task.Status = "completed"
	}

	_ = tm.saveTask(task)
}

// updateTaskStatus 更新任务状态
func (tm *FileTaskManager) updateTaskStatus(task *TaskInfo) {