我有這段 Go 代碼。我需要具備這種能力：在一個(gè)地方寫入通道，并在另一個(gè)地方讀出它們（反之亦然）：package mainimport "fmt"var ch1=make(chan int)var ch2=make(chan int)func f1() { select { case <- ch1:fmt.Println("ch1") default: fmt.Println("default") }}func f2() { select { case <- ch2:fmt.Println("ch2") default: fmt.Println("default") }}func main() { go f1() go f2() ch1<-1 ch2<-2}它總是這樣打?。篸efaultch1fatal error: all goroutines are asleep - deadlock!goroutine 1 [chan send]:main.main() /tmp/sandbox970110849/prog.go:22 +0xa0此外，我嘗試了這個(gè)：package mainimport ( "fmt" "sync")var ch1=make(chan int)var ch2=make(chan int)func f1() { select { case <- ch1:fmt.Println("ch1") default: fmt.Println("default") }}func f2() { select { case <- ch2:fmt.Println("ch2") default: fmt.Println("default") }}func w1() { ch1 <-1}func w2() { ch2 <-1}func main() { var wg sync.WaitGroup wg.Add(4) go f1() go f2() go w1() go w2() wg.Wait()}這次的錯誤更多：defaultch2fatal error: all goroutines are asleep - deadlock!goroutine 1 [semacquire]:sync.runtime_Semacquire(0x40e028, 0x0) /usr/local/go/src/runtime/sema.go:56 +0x40sync.(*WaitGroup).Wait(0x40e020, 0x14b720) /usr/local/go/src/sync/waitgroup.go:130 +0x60main.main() /tmp/sandbox916639182/prog.go:36 +0x100goroutine 8 [chan send]:main.w1() /tmp/sandbox916639182/prog.go:23 +0x40created by main.main /tmp/sandbox916639182/prog.go:34 +0xc0我哪里出錯了，如何解決？
2 回答
哆啦的時(shí)光機(jī)
TA貢獻(xiàn)1779條經(jīng)驗(yàn) 獲得超6個(gè)贊
您的main()函數(shù)嘗試在所有通道上發(fā)送，并且只有一次嘗試在單獨(dú)的并發(fā) goroutine 中從這些通道中讀取。這是否成功取決于 goroutine 調(diào)度程序。如果非阻塞接收f2()比發(fā)送更早安排main()，那么后面的發(fā)送main()將永遠(yuǎn)阻塞（沒有人會再次嘗試接收ch2）。
擺脫死鎖的一種方法是使用接收操作而不是非阻塞接收（在Go Playground上嘗試）：
func f1() {
<-ch1
fmt.Println("ch1")
}
func f2() {
<-ch2
fmt.Println("ch2")
}
因此，無論何時(shí)main()在這些通道上發(fā)送值，總會有一個(gè)接收器準(zhǔn)備好繼續(xù)，所以main()不會卡住。
請注意，當(dāng)main()返回時(shí)，應(yīng)用程序結(jié)束，它不會等待非主 goroutine 完成。因此，您可能無法在控制臺上看到ch1和打印。ch2有關(guān)詳細(xì)信息，請參閱Go 中的 goroutine 沒有輸出。
如果您的意圖是在您的應(yīng)用程序存在之前等待所有 goroutine 完成它們的工作，請使用sync.WaitGroup它（在Go Playground上嘗試）：
var ch1 = make(chan int)
var ch2 = make(chan int)
var wg sync.WaitGroup
func f1() {
defer wg.Done()
<-ch1
fmt.Println("ch1")
}
func f2() {
defer wg.Done()
<-ch2
fmt.Println("ch2")
}
func main() {
wg.Add(1)
go f1()
wg.Add(1)
go f2()
ch1 <- 1
ch2 <- 2
wg.Wait()
}
在此處查看更多示例：解決 goroutines 死鎖；并防止 main() 函數(shù)在 goroutine 在 Golang 中完成之前終止。
另一種選擇是為通道提供 1 的緩沖區(qū)，因此main()可以在沒有接收器準(zhǔn)備好從通道接收的情況下在通道上發(fā)送 1 值（在Go Playground上試試這個(gè)）：
var ch1 = make(chan int, 1)
var ch2 = make(chan int, 1)
有了這個(gè)，可以在沒有and的main()情況下繼續(xù)，所以再一次，不能保證你會看到任何打印出來的東西。f1()f2()
嚕嚕噠
TA貢獻(xiàn)1784條經(jīng)驗(yàn) 獲得超7個(gè)贊
此處使用的通道是無緩沖通道。
當(dāng) main goroutines 啟動時(shí)，它會創(chuàng)建兩個(gè)新的 goroutine f1 和 f2。
當(dāng)執(zhí)行 f1 或 f2 時(shí)，它將檢查我們是否在通道中有值，否則它將打印默認(rèn)消息并退出。
理想情況下，channels 會先發(fā)布值，然后通過 goroutine 接收
實(shí)際情況是 goroutine 通過打印默認(rèn)情況退出，但主 goroutine 試圖在通道中發(fā)布值，但由于沒有接收器，它面臨死鎖情況。
從第一個(gè)示例中刪除了死鎖，請參考鏈接： https: //play.golang.org/p/6RuQQwC9JkA
但是，如果 main 例程退出，所有關(guān)聯(lián)的 goroutine 將被自動終止。這就是為什么我們可以看到該值是任意打印的。
從第二個(gè)示例中刪除了死鎖，請參閱鏈接： https: //play.golang.org/p/yUmc_jjZMgV
sync.WaitGroup 正在讓 main goroutine 等待，這就是為什么我們可以在每次程序執(zhí)行時(shí)觀察輸出。
- 2 回答
- 0 關(guān)注
- 141 瀏覽
添加回答
舉報(bào)
0/150
提交
取消