为何该 goroutine 未触发 wg.Done() 呢？

在本文中，讨论了在 Go 语言中编写并发代码时遇到的问题。特别是，分析了以下代码中未调用 `wg.Done()` 的原因： ```go go func(taskArgs DoTaskArgs) { workerAddr :=

假设任意时刻registerchan上最多有两个元素（worker地址）。然后由于某种原因，下面的代码没有在最后两个 goroutine 中调用 wg.done() 。

func schedule(jobName string, mapFiles []string, nReduce int, phase jobPhase, registerChan chan string) {
    var ntasks int
    var nOther int // number of inputs (for reduce) or outputs (for map)
    switch phase {
    case mapPhase:
        ntasks = len(mapFiles)
        nOther = nReduce
    case reducePhase:
        ntasks = nReduce
        nOther = len(mapFiles)
    }

    fmt.Printf("Schedule: %v %v tasks (%d I/Os)\n", ntasks, phase, nOther)

    const rpcname = "Worker.DoTask"
    var wg sync.WaitGroup
    for taskNumber := 0; taskNumber < ntasks; taskNumber++ {
        file := mapFiles[taskNumber%len(mapFiles)]
        taskArgs := DoTaskArgs{jobName, file, phase, taskNumber, nOther}
        wg.Add(1)
        go func(taskArgs DoTaskArgs) {
            workerAddr := <-registerChan
            print("hello\n")
            // _ = call(workerAddr, rpcname, taskArgs, nil)
            registerChan <- workerAddr
            wg.Done()
        }(taskArgs)
    }
    wg.Wait()
    fmt.Printf("Schedule: %v done\n", phase)
}

如果我将 wg.done() 放在 registerchan <-workeraddr 之前，它就可以正常工作，我不知道为什么。我也尝试过推迟 wg.done() 但这似乎不起作用，尽管我期望它能起作用。我认为我对 go 例程和通道的工作方式存在一些误解，这导致了我的困惑。

解决方案

因为它停在这里：

workeraddr := <-registerchan

对于缓冲通道：
要使 workeraddr := <-registerchan 工作：通道 registerchan 必须有一个值；否则，代码将在此停止等待通道。

我设法以这种方式运行你的代码（尝试this）：

package main

import (
    "fmt"
    "sync"
)

func main() {
    registerchan := make(chan int, 1)
    for i := 1; i <= 10; i++ {
        wg.add(1)
        go fn(i, registerchan)
    }
    registerchan <- 0 // seed
    wg.wait()
    fmt.println(<-registerchan)
}

func fn(taskargs int, registerchan chan int) {
    workeraddr := <-registerchan
    workeraddr += taskargs
    registerchan <- workeraddr
    wg.done()
}

var wg sync.waitgroup

输出：

55

说明：
此代码使用通道和 10 个 goroutine 加上一个主 goroutine 将 1 与 10 相加。

我希望这会有所帮助。

当您运行此语句 registerchan <-workeraddr 时，如果通道容量已满，则无法添加它，并且它将阻塞。如果您有一个池，例如 10 个workeraddr，则可以在调用 schedule 之前将它们全部添加到容量为 10 的缓冲通道中。不要在调用后添加，以保证如果您从通道中获取值，之后有空间再次添加它。在 goroutine 的开头使用 defer 是很好的选择。

今天关于《为何该 goroutine 未触发 wg.Done() 呢？》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！