Go中如何准确统计和管理活跃的goroutine？

如何计算和显示活动 Goroutines 的数量

在这段代码中，我们有一个队列和一个执行出队和入队操作的函数 deen：

var element int

func deen(queue chan int) {
    element := <-queue
    fmt.Println("element is ", element)
    if element%2 == 0 {
        fmt.Println("new element is ", element)
        queue <- (element*100 + 11)
        queue <- (element*100 + 33)
    }
}

func main() {
    queue := make(chan int, 10)
    queue <- 1
    queue <- 2
    queue <- 3
    queue <- 0
    for len(queue) != 0 {
        for i := 0; i < 2; i++ {
            go deen(queue)
        }
    }
    fmt.Scanln()
    fmt.Println("list is has len", len(queue)) //this must be 0
}

但是，没有办法打印当前的活跃数量goroutines.

使用runtime.NumGoroutine

虽然有一种方法可以使用runtime.NumGoroutine获取活动goroutine的总数，但这不是最好的方法。这是因为循环会继续生成 goroutine，导致不必要的 CPU 消耗。

更好的方法：使用 Sync.WaitGroup

更有效的方法是使用sync.WaitGroup，它让我们跟踪活跃 goroutine 的数量。

func deen(wg *sync.WaitGroup, queue chan int) {
    for element := range queue {
        fmt.Println("element is ", element)
        if element%2 == 0 {
            fmt.Println("new element is ", element)
            wg.Add(2)
            queue <- (element*100 + 11)
            queue <- (element*100 + 33)
        }
        wg.Done()
    }
}

func main() {
    var wg sync.WaitGroup
    queue := make(chan int, 10)
    queue <- 1
    queue <- 2
    queue <- 3
    queue <- 0
    for i := 0; i < 4; i++ {
        wg.Add(1)
        go deen(&amp;wg, queue)
    }
    wg.Wait()
    close(queue)
    fmt.Println("list len", len(queue)) //this must be 0
}

这里，我们从四个开始goroutine 并等待它们完成工作后再关闭队列。这种方法提供了一种更干净、更受控的方式来管理活动 goroutine 的数量。

以上是Go中如何准确统计和管理活跃的goroutine？的详细内容。更多信息请关注PHP中文网其他相关文章！