我正在努力理解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
据我了解,延迟功能将在其周围的功能完成后执行。我无法解释。
如果我使用for循环从通道接收值,其工作方式如下。
for i := 0; i < 5; i++ {
fmt.Println(<-myIntChannel) //receiving value
}
有人可以帮助我理解这个概念吗?
仅当从通道接收到所有值并且通道已关闭时,通道上的[for ... range
才终止。
在您的示例中,您希望以延迟功能关闭通道,但是仅在main()
返回时才运行。但是main()
仅在循环结束时返回。这是导致死锁的原因。 for
循环等待通道关闭,并且关闭通道等待for循环结束。
当您使用循环从通道接收正好5个值时,它起作用了,因为启动的goroutine在其上发送了5个值。该循环不等待通道关闭,因此循环可以结束,main()
函数也可以结束。
这就是sender应该关闭通道(而不是接收器),并立即解决问题的原因:
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
为了用一些不同的术语来解释它,您的代码所做的是:
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
}
}