Go工作流中的任務狀態(tài)追蹤

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

以下是一個簡單的示例，展示了如何在Go中實現(xiàn)任務狀態(tài)追蹤：

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

type TaskStatus int

const (
    StatusPending TaskStatus = iota
    StatusRunning
    StatusCompleted
    StatusFailed
)

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

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

3. 創(chuàng)建一個函數(shù)來更新任務的狀態(tài)：

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來處理并發(fā)任務狀態(tài)更新：

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

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

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

    // 模擬任務狀態(tài)更新
    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)
    }()

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

    // 打印任務狀態(tài)
    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)
    }
}

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

// 任務狀態(tài)更新結構體
type TaskStatusUpdate struct {
    TaskID       int
    NewStatus    TaskStatus
}

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