日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當(dāng)前位置: 首頁 > 人文社科 > 生活经验 >内容正文

生活经验

Go 知识点(02)— channel 使用不当导致的 deadlock

發(fā)布時間:2023/11/28 生活经验 42 豆豆
生活随笔 收集整理的這篇文章主要介紹了 Go 知识点(02)— channel 使用不当导致的 deadlock 小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

運(yùn)行下面這段代碼輸出的結(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ā)送方和接收方必須同時準(zhǔn)備好才能保證消息的接收。而上面代碼發(fā)送方和接收方都在 main goroutine 中,所以兩者不可能同時運(yùn)行,必須是一前一后,這也就導(dǎo)致了發(fā)送方在一直等待接收方,而接收方由于發(fā)送方阻塞而不能執(zhí)行到,最終的結(jié)果是死鎖。

發(fā)送方在發(fā)送消息到通道的時候,此時如果接收方還沒有準(zhǔn)備好,那么發(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)
}

運(yùn)行后可以正常打印結(jié)果,所以有緩沖的通道不要求發(fā)送方和接收方同時準(zhǔn)備好,發(fā)送方將消息發(fā)送到通道中之后,就可以走了,接收方不管什么時候到,只需通道中消息直接取走就可以了。

但是我們繼續(xù)看下面這段代碼

func main() {c := make(chan string, 1) // 容量為 1 的有緩沖通道c <- "hello"c <- "world"fmt.Println(<-c)
}

運(yùn)行結(jié)果是什么呢?

fatal error: all goroutines are asleep - deadlock!

為什么有緩沖通道也會有死鎖呢?

原因在于此處創(chuàng)建了容量為 1 的緩沖通道,而在代碼中連續(xù)發(fā)送兩條消息,當(dāng)發(fā)送第一條消息后通道里面的消息個數(shù)就和容量相等了,此時再發(fā)送就只能等待通道中的消息被拿走才能繼續(xù)發(fā)送,在通道里面的消息沒有取走之前,發(fā)送方就會一直阻塞著。

即有緩沖的通道,當(dāng)通道信息個數(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)成 凡事有交代,件件有著落,事事有回音 的好習(xí)慣,要及時反饋當(dāng)前的狀態(tài)。

總結(jié)

以上是生活随笔為你收集整理的Go 知识点(02)— channel 使用不当导致的 deadlock的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯,歡迎將生活随笔推薦給好友。