Go無(wú)緩沖通道的陷阱是什么

本篇文章為大家展示了Go無(wú)緩沖通道的陷阱是什么，內(nèi)容簡(jiǎn)明扼要并且容易理解，絕對(duì)能使你眼前一亮，通過(guò)這篇文章的詳細(xì)介紹希望你能有所收獲。

定義

Channel是go的特色之一，甚至說(shuō)是最大的特色也不為過(guò)，使用起來(lái)也非常簡(jiǎn)單。
首先定義一個(gè)int類(lèi)型的channel：

ch2 := make(chan int) 
ch3 := make(chan int, 10)

我們這里主要關(guān)注無(wú)緩沖通道。

場(chǎng)景

來(lái)看看這段代碼：

package mainimport (
    "sync"
    "fmt")func main() {
    wg := sync.WaitGroup{}

    ch2 := make(chan int)

    wg.Add(1)

    for i := 0; i < 10; i++ {
        ch2 <- i
    }

    go func1(ch2, &wg) 

    wg.Wait()

    close(ch2)
    fmt.Println("Close channel: ", ch2)
}func func1(ch chan int, wg *sync.WaitGroup) {
    FOR:
    for {
        select {
        case i, ok := <- ch:
            if !ok {
                fmt.Println("1 chan closed, returning")
                break FOR
            } else {
                fmt.Println("1 Got number: ", i)
                if i == 9 {
                    break FOR
                }
            }
        default:
            fmt.Println("1 Got nothing")
        }
    }
    wg.Done()
}

乍眼一看似乎沒(méi)毛病，但是當(dāng)運(yùn)行程序的時(shí)候：

fatal error: all goroutines are asleep - deadlock!

goroutine 1 [chan send]:
main.main()
    /Users/bruce/Code/go/src/GoCommonServices/sync-demo/demo.go:19 +0xb9exit status 2Process finished with exit code 1

為什么呢？ 仔細(xì)看了看上面的程序，在定義了無(wú)緩沖通道ch2之后，立馬向其中寫(xiě)入數(shù)據(jù)：

    ch2 := make(chan int)

    for i := 0; i < 10; i++ {
        ch2 <- i
    }

但此時(shí)并沒(méi)有消費(fèi)者，而無(wú)緩沖通道在寫(xiě)入一個(gè)數(shù)據(jù)之后，會(huì)等待消費(fèi)者消費(fèi)，程序阻塞，但啟動(dòng)消費(fèi)者的代碼：

    go func1(ch2, &wg)

恰好在for循環(huán)之后，所以這個(gè)goroutine永遠(yuǎn)沒(méi)有啟動(dòng)的機(jī)會(huì)，這就是報(bào)錯(cuò)信息提示的，deadlock了，要修復(fù)這個(gè)有兩種方法：

1 ch2定義為緩沖通道，足夠容納for中的數(shù)據(jù)，就不會(huì)阻塞

    ch2 := make(chan int， 10)

2 先啟動(dòng)消費(fèi)者，再向通道中寫(xiě)數(shù)據(jù)

    go func1(ch2, &wg) 

    ch2 := make(chan int)

    for i := 0; i < 10; i++ {
        ch2 <- i
    }

歸根結(jié)底，還是因?yàn)閏hannel的特性：

無(wú)緩沖的channel，不管是入還是出，都會(huì)阻塞，所以在同一個(gè)goroutine中，不能同時(shí)對(duì)同一個(gè)無(wú)緩沖channel進(jìn)行入和出操作；

帶緩沖的channel，在隊(duì)列滿(mǎn)之前，不會(huì)阻塞；隊(duì)列滿(mǎn)之后，依然會(huì)阻塞。

go是什么

golang是一種編譯語(yǔ)言，可以將代碼編譯為機(jī)器代碼，編譯后的二進(jìn)制文件可以直接部署到目標(biāo)機(jī)器而無(wú)需額外的依賴(lài)，所以golang的性能優(yōu)于其他的解釋性語(yǔ)言，且可以在golang中使用goroutine來(lái)實(shí)現(xiàn)并發(fā)性，它提供了一個(gè)非常優(yōu)雅的goroutine調(diào)度程序系統(tǒng)，可以很容易地生成數(shù)百萬(wàn)個(gè)goroutine。

上述內(nèi)容就是Go無(wú)緩沖通道的陷阱是什么，你們學(xué)到知識(shí)或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備，歡迎關(guān)注億速云行業(yè)資訊頻道。