我正在努力理解 Go 中的并發性。package mainimport "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 }}上面的代碼給出了以下輸出：01234fatal 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 回答
呼啦一陣風
TA貢獻1802條經驗 獲得超6個贊
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
四季花海
TA貢獻1811條經驗 獲得超5個贊
用不同的術語來解釋它，您的代碼所做的是：
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
}
}
- 2 回答
- 0 關注
- 171 瀏覽
添加回答
舉報
0/150
提交
取消