Go语言工作流中的任务执行状态跟踪

在Go语言中，可以使用goroutine和channel来实现任务执行状态的跟踪。goroutine是Go语言中的轻量级线程，可以并发执行多个任务。channel是一种同步机制，可以在不同的goroutine之间传递数据。

下面是一个简单的示例，展示了如何使用goroutine和channel来跟踪任务执行状态：

package main

import (
	"fmt"
	"sync"
	"time"
)

func worker(id int, wg *sync.WaitGroup, status chan<- string) {
	defer wg.Done()

	// 模拟任务执行时间
	time.Sleep(time.Duration(id) * time.Second)

	// 将任务执行状态发送到channel
	status <- fmt.Sprintf("Task %d completed", id)
}

func main() {
	var wg sync.WaitGroup
	status := make(chan string, 10) // 创建一个带缓冲的channel

	// 启动5个任务
	for i := 1; i <= 5; i++ {
		wg.Add(1)
		go worker(i, &wg, status)
	}

	// 等待所有任务完成
	go func() {
		wg.Wait()
		close(status) // 关闭channel
	}()

	// 接收任务执行状态
	for s := range status {
		fmt.Println(s)
	}
}

在这个示例中，我们创建了一个名为worker的函数，它接受一个任务ID、一个WaitGroup指针和一个只发送（send-only）的channel。worker函数模拟任务执行时间，然后将任务执行状态发送到channel。

在main函数中，我们创建了一个带缓冲的channel，用于存储任务执行状态。我们启动了5个任务，并使用WaitGroup等待所有任务完成。一旦所有任务完成，我们关闭channel。最后，我们从channel中接收任务执行状态并打印出来。

这个示例展示了如何使用goroutine和channel来跟踪任务执行状态。你可以根据自己的需求调整代码，以适应不同的工作流场景。