为什么关闭通道后会导致死锁，即使我已发送所有值

关闭通道后会导致死锁，即使已发送所有值，是因为通道上的接收操作会在通道关闭后继续等待，而不会接收到任何新值。这导致了主协程被阻塞，因为接收操作无法完成。要解决此问题，需要在发送所有值后关闭通道，并使用 waitgroup 或类似机制等待所有 goroutine 完成。

为什么打印所有值后出现死锁？ 我明白什么 从接收部分代码开始，通道正在等待，尽管我尝试使用 waitgroup 不起作用，但让其阻止或暂停主 go 例程

package main

import (
    "fmt"
    //"sync"
)

//output  from 10 20 30 ... - 100
func main() {
    //wg := sync.WaitGroup{}

    done := make(chan int)
    for i := 1; i <= 10; i++ {
        //wg.Add(1)
        go func(i int) {

            done <- i * 10
        }(i)
        // close(done)
    }
    //  close(done)
    //wg.Wait()

    // for item := range done{
    // fmt.Println(item)}
    for {
        if value, ok := <-done; ok {
            fmt.Println("received is ", value)
        } else {
            return
            //os.Exit(1)
        }
    }
}

正确答案

根据 @aureliar value 的回答，ok := <-done 将阻塞，直到通道上收到一个值或通道关闭（并且，一旦你的 goroutine 完成，这些都不会发生）。从您的问题和代码中的注释来看，您似乎已经接近弄清楚如何通过等待 goroutine 完成并关闭通道来解决此问题。

因为你提前知道 goroutine 的数量（并且每个 goroutine 总是在通道上发送一个值），所以有一个简单的解决方案（playground）：

func main() {
    noofgoroutines := 10
    done := make(chan int)
    for i := 1; i <= noofgoroutines; i++ {
        go func(i int) {
            done <- i * 10
        }(i)
    }

    for noofgoroutines > 0 {
        value := <-done
        fmt.println("received is ", value)
        noofgoroutines--
    }
}

当您不知道提前收到多少值时，事情会变得有点复杂。在这种情况下，关闭通道是让接收者知道您已完成的好方法。在您的情况下，这意味着在 goroutine 完成后关闭通道（这很重要，因为发送到关闭的通道会导致恐慌）。

要使用 waitgroup 执行此操作，您将需要三个函数：

• wg.Add(delta int) 设置计数器。您注释掉的调用很好，但另一种方法是在进入循环之前调用 wg.add(10)。
• wg.Done()“将 waitgroup 计数器减一” - 您需要在每个 goroutine 结束之前调用此函数（对于 defer 调用很常见）。您的代码中缺少此内容。
• wg.Wait()“阻塞直到 waitgroup 计数器为零”。

完成上述操作后，您可以安全地调用 close(done) ，因为知道不会再向通道发送任何内容。然而，有一个复杂的情况 - 如果您只是在第一个循环之后添加此代码，您将遇到另一个死锁，因为您的 goroutine 将全部阻塞在 done <- i * 10 处。发生这种情况是因为 main 将在 wg.wait() 处被阻止，这意味着没有从通道接收任何内容，并且根据 the spec：

如果容量为零或不存在，则通道不缓冲，并且仅当发送方和接收方都准备好时通信才会成功。

这可以通过在另一个 goroutine 中等待/关闭来解决。

您可以在the playground中尝试此操作。

package main

import (
    "fmt"
    "sync"
)

//output  from 10 20 30 ... - 100
func main() {
    wg := sync.waitgroup{}

    done := make(chan int)
    for i := 1; i <= 10; i++ {
        wg.add(1)
        go func(i int) {
            done <- i * 10
            wg.done()
        }(i)
    }

    go func() {
        wg.wait()
        close(done)
    }()

    for value := range done {
        fmt.println("received is ", value)
    }
    fmt.println("channel closed")

    /* i have simplified your loop but this would also work
    for {
        if value, ok := <-done; ok {
            fmt.println("received is ", value)
        } else {
            fmt.println("channel closed")
            return
        }
    }
    */
}

因为你从来不关闭频道。所以 value, ok := <-done 部分总是在等待永远不会到来的第 11 个值。

更换这部分应该可以解决问题：

for i := 1; i <= 10; i++ {
    //wg.add(1)
    go func(i int) {

        done <- i * 10
    }(i)
    // close(done)
}

新：

go func(){
   for i := 1; i <= 10; i++ {
            done <- i * 10 
    }
    close(done)
}()

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。