go - for循环导致死锁

Question

我已经从 GO Concurrency 写了一些代码示例:

func gen(numbers ...int) <-chan int {
    out := make(chan int)

    go func() {
        for _, number := range numbers {
            out <- number
        }
        close(out)
    }()

    return out
}

func sq(in <-chan int) <-chan int {
    out := make(chan int)

    go func() {
        for number := range in {
            out <- number * number
        }
    }()

    return out
}

所以我尝试在我的主要函数中使用上面的代码，如下所示:

func main() {



    result := sq(sq(sq(gen(1, 2, 3, 4))))

    fmt.Println(<-result)
    fmt.Println(<-result)
    fmt.Println(<-result)
    fmt.Println(<-result)

    fmt.Println("-------------------")

    for channelValue := range sq(sq(sq(gen(1, 2, 3, 4)))) {
        fmt.Println(channelValue)
    }

}

当我运行代码时我很困惑我在循环后得到了这条消息:

fatal error: all goroutines are asleep - deadlock

请帮助我理解这一点。据我了解，调用 fmt.Prinlnt(result) x 4 次与 for channelValue := range sq(sq(sq(gen(1, 2) 上的 for 循环相同, 3, 4))))。这是正确的吗？

能告诉我为什么在循环后出现死锁吗？

Answer 1

channel block 上方的范围，因为 channel 未在 sq 中关闭。

func sq(in <-chan int) <-chan int {
  out := make(chan int)

  go func() {
    for number := range in {
        out <- number * number
    }
    close(out)
  }()

  return out
}

调试此类死锁的一个好方法是向进程发送一个 SIGQUIT。当收到 SIGQUIT 时，运行时会转储所有 goroutine 的堆栈。堆栈转储通常会指出问题所在。