我正在努力理解 Go 中的并發(fā)性。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根據(jù)我的理解，延遲函數(shù)將在其周圍函數(shù)完成后執(zhí)行。我無法解釋它。如果我使用 for 循環(huán)從通道接收值，其工作原理如下。for i := 0; i < 5; i++ { fmt.Println(<-myIntChannel) //receiving value}誰能幫助我理解這個(gè)概念？
2 回答
BIG陽
TA貢獻(xiàn)1859條經(jīng)驗(yàn) 獲得超6個(gè)贊
for ... range僅當(dāng)從通道接收到所有值并且通道已關(guān)閉時(shí)，通道上的操作才會(huì)終止。
在您的示例中，您希望在延遲函數(shù)中關(guān)閉通道，但這只會(huì)在main()返回時(shí)運(yùn)行。但main()只有在循環(huán)結(jié)束時(shí)才會(huì)返回。這就是死鎖的原因。循環(huán)for等待通道關(guān)閉，關(guān)閉通道等待for循環(huán)結(jié)束。
當(dāng)您使用循環(huán)從通道接收恰好 5 個(gè)值時(shí)，它會(huì)起作用，因?yàn)閱?dòng)的 Goroutine 會(huì)在其上發(fā)送 5 個(gè)值。該循環(huán)不會(huì)等待通道關(guān)閉，因此循環(huán)可以結(jié)束，函數(shù)也可以結(jié)束main()。
這就是為什么發(fā)送者應(yīng)該關(guān)閉通道（而不是接收者），問題就立即解決：
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貢獻(xiàn)1795條經(jīng)驗(yàn) 獲得超7個(gè)贊
用稍微不同的術(shù)語來解釋它，您的代碼的作用是：
func main() {
...
while myIntChannel is not closed {
...
}
close myIntChannel
}
現(xiàn)在您可以看到僵局從何而來。
雖然上面的答案是有效的，但如果您更喜歡使用，您也可以嘗試這個(gè)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 關(guān)注
- 220 瀏覽
添加回答
舉報(bào)
0/150
提交
取消