Go工作流中的任務狀態追蹤

在Go語言的工作流（workflow）中，任務狀態追蹤是一個重要的功能，它可以幫助我們了解任務的執行進度、狀態變化以及可能存在的問題。為了實現這個功能，我們可以使用Go的并發特性（如goroutines和channels）來處理任務的狀態變化，并使用合適的數據結構（如map或slice）來存儲和管理這些狀態信息。

以下是一個簡單的示例，展示了如何在Go中實現任務狀態追蹤：

1. 首先，定義一個表示任務狀態的枚舉類型：

type TaskStatus int

const (
    StatusPending TaskStatus = iota
    StatusRunning
    StatusCompleted
    StatusFailed
)

2. 接下來，創建一個結構體來表示任務，包括任務ID、狀態以及其他相關信息：

type Task struct {
    ID            int
    Status        TaskStatus
    StartTime     time.Time
    EndTime       time.Time
    Progress      float64 // 0.0到1.0之間的值，表示任務的完成度
    Error         error
}

3. 創建一個函數來更新任務的狀態：

func UpdateTaskStatus(task *Task, newStatus TaskStatus) {
    task.Status = newStatus
    switch newStatus {
    case StatusCompleted:
        task.EndTime = time.Now()
        task.Progress = 1.0
    case StatusFailed:
        task.EndTime = time.Now()
    }
}

4. 使用goroutines和channels來處理并發任務狀態更新：

func main() {
    // 創建一個任務列表
    tasks := []Task{
        {ID: 1, Status: StatusPending},
        {ID: 2, Status: StatusRunning},
        {ID: 3, Status: StatusPending},
    }

    // 創建一個channel來接收任務狀態更新的信號
    statusUpdates := make(chan TaskStatusUpdate)

    // 啟動一個goroutine來處理任務狀態更新
    go func() {
        for update := range statusUpdates {
            task := findTaskByID(tasks, update.TaskID)
            if task != nil {
                UpdateTaskStatus(task, update.NewStatus)
            }
        }
    }()

    // 模擬任務狀態更新
    go func() {
        time.Sleep(time.Second)
        statusUpdates <- TaskStatusUpdate{TaskID: 1, NewStatus: StatusRunning}
        time.Sleep(time.Second)
        statusUpdates <- TaskStatusUpdate{TaskID: 1, NewStatus: StatusCompleted}
        time.Sleep(time.Second)
        statusUpdates <- TaskStatusUpdate{TaskID: 2, NewStatus: StatusFailed}
        close(statusUpdates)
    }()

    // 等待所有任務狀態更新完成
    time.Sleep(5 * time.Second)

    // 打印任務狀態
    for _, task := range tasks {
        fmt.Printf("Task %d: Status: %s, Start: %v, End: %v, Progress: %.2f\n",
            task.ID, task.Status, task.StartTime, task.EndTime, task.Progress)
    }
}

// 輔助函數：根據任務ID查找任務
func findTaskByID(tasks []Task, taskID int) *Task {
    for _, task := range tasks {
        if task.ID == taskID {
            return &task
        }
    }
    return nil
}

// 任務狀態更新結構體
type TaskStatusUpdate struct {
    TaskID       int
    NewStatus    TaskStatus
}

在這個示例中，我們創建了一個任務列表，并使用一個goroutine來處理并發任務狀態更新。我們還模擬了一些任務狀態更新，并在主函數中打印了任務的最終狀態。這只是一個簡單的示例，實際的工作流可能需要更復雜的邏輯和功能。