Go语言 为什么延迟函数不执行?

nwnhqdif  于 2023-09-28  发布在  Go
关注(0)|答案(2)|浏览(114)

我正在努力理解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
}

谁能帮我理解一下这个概念?

ebdffaop

ebdffaop1#

仅当从通道接收到所有值并且通道已关闭时,通道上的for ... range才终止。
在你的例子中,你希望在一个延迟函数中关闭通道,但这只会在main()返回时运行。但是main()只有在循环结束时才会返回。这就是造成僵局的原因。for循环等待通道关闭,关闭通道等待for循环结束。
当你使用一个循环从通道中接收5个值时,它是有效的,因为启动的goroutines会发送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上尝试):

0
1
2
3
4
xzv2uavs

xzv2uavs2#

用稍微不同的术语来解释它,你的代码所做的是:

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
    }
}

相关问题