我正在努力理解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
}
谁能帮我理解一下这个概念?
2条答案
按热度按时间ebdffaop1#
仅当从通道接收到所有值并且通道已关闭时,通道上的
for ... range
才终止。在你的例子中,你希望在一个延迟函数中关闭通道,但这只会在
main()
返回时运行。但是main()
只有在循环结束时才会返回。这就是造成僵局的原因。for
循环等待通道关闭,关闭通道等待for循环结束。当你使用一个循环从通道中接收5个值时,它是有效的,因为启动的goroutines会发送5个值。这个循环不会等待通道关闭,因此循环可以结束,
main()
函数也可以结束。这就是为什么发送方应该关闭通道(而不是接收方),问题立即得到解决:
输出(在Go Playground上尝试):
xzv2uavs2#
用稍微不同的术语来解释它,你的代码所做的是:
现在您可以看到死锁的来源了。
虽然上面的答案是有效的,但如果你更喜欢使用
defer
,你也可以尝试这样做: