go - 与 defer wg.Done 和 channel 混淆

Question

我在使用 defer wg.Done 和 channel 时遇到问题。

如果我像下面这样编码，就没有问题。

for i := 0; i < ntasks; i++ {
    wg.Add(1)
    go func(args DoTaskArgs) {
        // defer wg.Done()
        for {
            worker := <-registerChan
            ok := call(worker, "Worker.DoTask", &args, nil)
            if ok {
                wg.Done()
                // go func() {
                registerChan <- worker
                // }()
                break
            }
        }
    }(DoTaskArgs{jobName, mapFiles[i], phase, i, n_other})
}
wg.Wait()

但如果我使用 defer wg.Done() ，代码将被卡住，除非包装 registerChan <- worker与 go func .

for i := 0; i < ntasks; i++ {
    wg.Add(1)
    go func(args DoTaskArgs) {
        defer wg.Done()
        for {
            worker := <-registerChan
            ok := call(worker, "Worker.DoTask", &args, nil)
            if ok {
                // go func() {
                registerChan <- worker
                // }()
                break
            }
        }
    }(DoTaskArgs{jobName, mapFiles[i], phase, i, n_other})
}
wg.Wait()

这里有什么问题？

Answer 1

好吧，首先，您的 channel 使用困惑并且会阻塞。在 goroutine 中，它从 channel 中读取。但没有写入任何内容。

我不认为你的问题与延迟有任何关系。