为什么延迟函数不执行？

Question

我正在努力理解 Go 中的并发。

package main

import "fmt"

func sendValues(myIntChannel chan int) {
    for i := 0; i < 5; i++ {
        myIntChannel <- i //sending value
    }
}

func main() {
    myIntChannel := make(chan int)
    defer close(myIntChannel)
    go sendValues(myIntChannel)

    for value := range myIntChannel {
        fmt.Println(value) //receiving value
    }
}

以上代码给出以下输出：

0
1
2
3
4
fatal error: all goroutines are asleep - deadlock!

goroutine 1 [chan receive]:
main.main()
    /Users/spikki/Desktop/GoLearning/go_channel.go:51 +0x10b

根据我的理解，defer函数会在其周围的函数完成后执行。我无法解释它。

如果我使用 for 循环从通道接收值，其工作方式如下。

for i := 0; i < 5; i++ {
    fmt.Println(<-myIntChannel) //receiving value
}

谁能帮我理解这个概念？

Answer 1

for ... range 只有在从通道接收到所有值并且通道已关闭后，通道才会终止。

在您的示例中，您希望在延迟函数中关闭通道，但这只会在 main() return 时运行。但是 main() 只有在循环结束时才会 return 。这就是死锁的原因。 for循环等待通道关闭，关闭通道等待for循环结束。

当您使用循环从通道接收恰好 5 个值时，它会起作用，因为启动的 goroutine 会在其上发送 5 个值。此循环不等待通道关闭，因此循环可以结束，main() 函数也可以。

这就是为什么 发送者 应该关闭通道（而不是接收者），问题立即解决：

func sendValues(myIntChannel chan int) {
    for i := 0; i < 5; i++ {
        myIntChannel <- i //sending value
    }
    close(myIntChannel)
}

func main() {
    myIntChannel := make(chan int)
    go sendValues(myIntChannel)

    for value := range myIntChannel {
        fmt.Println(value) //receiving value
    }
}

输出（在 Go Playground 上尝试）：

Answer 2

为了用不同的术语解释它，您的代码所做的是：

func main() {
    ...
    while myIntChannel is not closed {
        ...
    }
    close myIntChannel 
}

现在你可以看到死锁是从哪里来的了。

虽然上述答案有效，但如果您更喜欢使用 defer:

，您也可以试试这个

func sendValues(myIntChannel chan int) {
    defer close(myIntChannel)
    for i := 0; i < 5; i++ {
        myIntChannel <- i //sending value
    }
}

func main() {
    myIntChannel := make(chan int)

    go sendValues(myIntChannel)

    for value := range myIntChannel {
        fmt.Println(value) //receiving value
    }
}

为什么延迟函数不执行？

Why doesn't deferred function execute?

concurrency

for-loop

channel

go

deferred