Go 知识点(02)— channel 使用不当导致的 deadlock
運行下面這段代碼輸出的結(jié)果是什么?
package mainimport ("fmt"
)func main() {c := make(chan string) // 創(chuàng)建一個無緩沖的通道c <- "hello world"fmt.Println(<-c)
}
答案是:會發(fā)生死鎖
fatal error: all goroutines are asleep - deadlock!
原因是:對于無緩沖通道,發(fā)送方和接收方必須同時準備好才能保證消息的接收。而上面代碼發(fā)送方和接收方都在 main goroutine 中,所以兩者不可能同時運行,必須是一前一后,這也就導致了發(fā)送方在一直等待接收方,而接收方由于發(fā)送方阻塞而不能執(zhí)行到,最終的結(jié)果是死鎖。
發(fā)送方在發(fā)送消息到通道的時候,此時如果接收方還沒有準備好,那么發(fā)送方就會一直阻塞著,等待著接收方的到來,如果接收方一直沒在就會造成死鎖。
如何解決這個問題呢?
我們要知道通道一般適用于不同的協(xié)程之間信息的交互,所以要解決上面問題,我們可以讓發(fā)送方和接收方處于不同的協(xié)程中。
見下面代碼
func main() {ch := make(chan string) // 創(chuàng)建一個無緩沖的通道// 啟動一個協(xié)程go func(c chan string) {c <- "hello world"}(ch)fmt.Println(<-ch)
}
輸出結(jié)果如下:
hello world
而有緩沖通道則不會出現(xiàn)上述的死鎖問題
func main() {c := make(chan string, 1) // 容量為 1 的有緩沖通道c <- "hello world"fmt.Println(<-c)
}
運行后可以正常打印結(jié)果,所以有緩沖的通道不要求發(fā)送方和接收方同時準備好,發(fā)送方將消息發(fā)送到通道中之后,就可以走了,接收方不管什么時候到,只需通道中消息直接取走就可以了。
但是我們繼續(xù)看下面這段代碼
func main() {c := make(chan string, 1) // 容量為 1 的有緩沖通道c <- "hello"c <- "world"fmt.Println(<-c)
}
運行結(jié)果是什么呢?
fatal error: all goroutines are asleep - deadlock!
為什么有緩沖通道也會有死鎖呢?
原因在于此處創(chuàng)建了容量為 1 的緩沖通道,而在代碼中連續(xù)發(fā)送兩條消息,當發(fā)送第一條消息后通道里面的消息個數(shù)就和容量相等了,此時再發(fā)送就只能等待通道中的消息被拿走才能繼續(xù)發(fā)送,在通道里面的消息沒有取走之前,發(fā)送方就會一直阻塞著。
即有緩沖的通道,當通道信息個數(shù)等于通道容量時,發(fā)送方就會一直阻塞,直到接收方將消息取走,有剩余的容量時發(fā)送方才會繼續(xù)發(fā)送。
那么,如果發(fā)送發(fā)已經(jīng)發(fā)送完畢,接收方一直等待取消息,會發(fā)生什么情況?
func main() {ch := make(chan string)go func() {ch <- "hello"ch <- "world"}()for data := range ch {fmt.Println(data)}
}
輸出結(jié)果:
hello
world
fatal error: all goroutines are asleep - deadlock!
又又發(fā)生死鎖了,這又是為什么呢?
原因就在于發(fā)送方發(fā)送完成后就不管了,但是呢?接收方又不知道發(fā)送方有沒有發(fā)送完成,就傻乎乎的一直等待下去,最后就造成死鎖了。
如何解決呢?
我們只需要在發(fā)送方發(fā)送完畢后告訴接收方,我已經(jīng)發(fā)送完了,你取了最后一個消息就回家吧,媳婦、兒子等你回家呢。
怎樣告訴接收方呢?很簡單使用 close() 關(guān)閉通道即可。
func main() {ch := make(chan string)go func() {ch <- "hello"ch <- "world"close(ch) // 發(fā)送完畢后關(guān)閉通道}()for data := range ch {fmt.Println(data)}
}
所以呢,我們也要養(yǎng)成 凡事有交代,件件有著落,事事有回音 的好習慣,要及時反饋當前的狀態(tài)。
總結(jié)
以上是生活随笔為你收集整理的Go 知识点(02)— channel 使用不当导致的 deadlock的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 2022-2028年中国激光脱毛仪行业市
- 下一篇: 2022-2028年中国PPS树脂产业研