使用 chan 和 sync.waitgroup 时的死锁

Question

我目前正在学习并发。我编写了一个简单的测试程序来练习 goroutines。但是每当我执行此操作时，我都会收到一条错误消息，指出fatal error: all goroutines are asleep - deadlock!我不知道我做错了什么。有谁知道我如何使这项工作按预期进行。任何帮助都感激不尽

import (

    "fmt"

    "sync"

    "time"

)

func slow(i int, cha chan int, wg *sync.WaitGroup) {

    fmt.Println("HI", i)

    time.Sleep(time.Second * 2)

    cha <- i * 2

    wg.Done()

}

func main() {

    var wg sync.WaitGroup

    values := make(chan int)

    for i := 1; i < 12; i++ {

        wg.Add(1)

        go slow(i, values, &wg)

    }

    wg.Wait()

    close(values)

}

编辑：当我尝试将通道设置为缓冲通道时，它可以工作。我不知道怎么

Answer 1

您当前的程序无法运行，因为无缓冲通道没有消费者。此外，没有必要同时使用WaitGroup两者channel。考虑下面的例子：func slow(i int, cha chan int) {&nbsp; fmt.Println("HI", i)&nbsp; time.Sleep(time.Second * 2)&nbsp; cha <- i * 2}func main() {&nbsp; values := make(chan int)&nbsp; defer close(values)&nbsp; for i := 1; i < 12; i++ {&nbsp; &nbsp; go slow(i, values)&nbsp; }&nbsp; for i := 1; i < 12; i++ {&nbsp; &nbsp; fmt.Println(<-values)&nbsp; }}这样我们就可以有一个发送者 goroutine，并且可以在主函数中使用消息。如果我们只是想确保所有的 goroutine 在 main 完成执行之前完成，我们可以像下面这样删除通道：func slow(i int, wg *sync.WaitGroup) {&nbsp; &nbsp; fmt.Println("HI", i)&nbsp; &nbsp; time.Sleep(time.Second * 2)&nbsp; &nbsp; wg.Done()}func main() {&nbsp; &nbsp; var wg sync.WaitGroup&nbsp; &nbsp; for i := 1; i < 12; i++ {&nbsp; &nbsp; &nbsp; &nbsp; wg.Add(1)&nbsp; &nbsp; &nbsp; &nbsp; go slow(i, &wg)&nbsp; &nbsp; }&nbsp; &nbsp; wg.Wait()}使用缓冲通道有效，因为在缓冲区填满之前将消息推送到通道不再阻塞。