Go 跟踪长时间运行的任务的进度 正确的方法

我想跟踪一些长时间运行的进程的执行情况，并显示用户完成百分比和错误(如果有).如果是one个长时间运行的进程，那么就很容易了——您可以为进度(百分比)和错误创建通道.当我们有X个长时间运行的进程时，实现这种逻辑的正确方法是什么？

下面是一段有效的代码，但我真的不喜欢它的实现方式.

这是惯用的解决方案吗？将ProgressTracker作为通道传递给函数会更容易，但我不知道在这种情况下如何正确发送"进度"、"错误"和"完成"事件.

代码如下，围棋场也有相同的代码:https://go.dev/play/p/f3hXJsZR9WV

package main

import (
    "errors"
    "fmt"
    "strings"
    "sync"
    "time"
)

type ProgressTracker struct {
    Progress chan int
    Error    chan error
    Complete chan bool
    Url      string
}

/**
This method sleeps for 1 second and sends progress (in %) in each iteration to Progress channel
For .net sites on 3rd iteration fail with error
When everything is completed, send a message to Complete channel
*/
func work(url string, tracker *ProgressTracker) {
    tracker.Url = url
    fmt.Printf("processing url %s\n", url)
    for i := 1; i <= 5; i++ {
        time.Sleep(time.Second)
        if i == 3 && strings.HasSuffix(url, ".net") {
            tracker.Error <- errors.New("emulating error for .net sites")
            tracker.Complete <- true
        }
        progress := 20 * i
        tracker.Progress <- progress
    }
    tracker.Complete <- true
}

func main() {
    var trackers []*ProgressTracker
    var urls = []string{"google.com", "youtube.com", "someurl.net"}
    var wg sync.WaitGroup
    
    wg.Add(len(urls))
    for _, url := range urls {
        tracker := &ProgressTracker{
            Progress: make(chan int),
            Error:    make(chan error),
            Complete: make(chan bool),
        }
        trackers = append(trackers, tracker)
        go func(workUrl string, progressTracker *ProgressTracker) {
            work(workUrl, progressTracker)
        }(url, tracker)
    }

    go func() {
        wg.Wait()
    }()

    var processed = 0

    //iterate through all trackers and select each channel.
    //Exit from this loop when number of processed requests equals the number of trackers
    for {
        for _, t := range trackers {
            select {
            case pr := <-t.Progress:
                fmt.Printf("Url = %s, progress = %d\n", t.Url, pr)
            case err := <-t.Error:
                fmt.Printf("Url = %s, error = %s\n", t.Url, err.Error())
            case <-t.Complete:
                fmt.Printf("Url = %s is completed\n", t.Url)
                processed = processed + 1
                if processed == len(trackers) {
                    fmt.Printf("Everything is completed, exit")
                    return
                }
            }
        }
    }
}

UPD:

func work(url string, tracker *ProgressTracker) {
    tracker.Url = url
    fmt.Printf("processing url %s\n", url)
    for i := 1; i <= 5; i++ {
        if url == "google.com" {
            time.Sleep(time.Second * 3)
        }
        time.Sleep(time.Second)
        if i == 3 && strings.HasSuffix(url, ".net") {
            tracker.Error <- errors.New("emulating error for .net sites")
            tracker.Complete <- true
            return
        }
        progress := 20 * i
        tracker.Progress <- progress
    }
    tracker.Complete <- true
}