使用 chan 和 sync.waitgroup 时出现死锁

Question

我目前正在学习 go 中的并发。我写了一个简单的测试程序来练习 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) {
  fmt.Println("HI", i)
  time.Sleep(time.Second * 2)
  cha <- i * 2
}

func main() {
  values := make(chan int)
  defer close(values)
  for i := 1; i < 12; i++ {
    go slow(i, values)
  }

  for i := 1; i < 12; i++ {
    fmt.Println(<-values)
  }
}

这样我们就可以有一个发送者 goroutine 并且可以在主函数中使用消息。

如果我们只想确保所有 goroutine 在 main 完成执行之前完成，我们可以像下面这样删除通道：

func slow(i int, wg *sync.WaitGroup) {
    fmt.Println("HI", i)
    time.Sleep(time.Second * 2)
    wg.Done()
}

func main() {
    var wg sync.WaitGroup
    for i := 1; i < 12; i++ {
        wg.Add(1)
        go slow(i, &wg)
    }
    wg.Wait()
}

使用缓冲通道有效，因为在缓冲区填满之前将消息推送到通道不再阻塞。

使用 chan 和 sync.waitgroup 时出现死锁

Deadlock When using chan and sync.waitgroup

concurrency

channel

go

goroutine