Go通道channel通過通信共享內存

Posted on by

引言

不要通過共享內存來通信 應該通過通信來共享內存

這句話有網友的解釋如下：

這句俏皮話具體說來就是，不同的線程不共享內存不用鎖，線程之間通訊用通道(channel)同步也用channel。

chanel是協程之間傳遞信息的媒介，優雅地解決瞭某些後端開發常用語言中隨處可見的lock，unlock，臨界區等，把從很多線程層面解決的問題移到協程，從而靜態地保證沒有數據競爭。

通道的聲明與創建

偽代碼如下：

//聲明類型
var 通道名 chan 數據類型
//創建通道
通道名 = make(chan 數據類型)

實際例子如下：

package main
import "fmt"
func main() {
    var a chan int
    fmt.Printf("%T, %v\n", a, a)
    if a == nil {
        a = make(chan int)
        fmt.Printf("%T, %v\n", a, a)
    }
}

運行結果是：

chan int, <nil>
chan int, 0x1400001a360

通道是一個內存地址，這也說明瞭其實一個引用類型的數據。

接收 & 發送數據

對於同一個通道來講,他的讀數據 和 寫數據 都是阻塞的。
偽代碼如下：

//從通道讀數據
data := <-a
//把數據寫入通道
a <- data

實際例子如下：

package main
import "fmt"
func main() {
    //    首先創建一個bool類型的通道
    var ch1 chan bool
    ch1 = make(chan bool)
    //下面啟動一個go routine
    go func() {
        for i := 0; i &lt; 10; i++ {
            fmt.Println("子goroutine中， i: ", i)
        }
        fmt.Println("completed")
        //循環結束後 向團隊中寫數據，表示要結束瞭
        ch1 &lt;- true
    }()
    //在主程序中讀取數據
    data := &lt;-ch1
    //打印一下 我們讀到的數據
    fmt.Println("main  data: ", data)
    fmt.Println("main goroutine completed")
}

運行結果如下：

子goroutine中， i: 0
子goroutine中， i: 1
子goroutine中， i: 2
子goroutine中， i: 3
子goroutine中， i: 4
子goroutine中， i: 5
子goroutine中， i: 6
子goroutine中， i: 7
子goroutine中， i: 8
子goroutine中， i: 9
completed
main data: true
main goroutine completed

我們的子goroutine裡面 循環打印1~10， 打印完成之後 把chanel類型的ch1寫為true，
這時候，主goroutine就可以根據這一條件進行下一步瞭，，在此之前，其實就算主goroutine先搶到瞭資源，從ch1中讀取數據，但是現在通道裡面啥都沒有，隻能阻塞，然後乖乖交出資源給我們的子goroutine，直到循環結束寫true入ch1。

需要註意的有以下幾點：

  • chanel是需要指定類型的 nil類型的chanel不能直接使用。
  • chanel本身是同步的，同一時間隻能有一條goroutine進行操作。
  • chanel是goroutine之間傳遞數據用的，chanel數據的發送和接收必須在不同的goroutine中，如果隻有一條goroutine是用不上chanel的，這種情況會發生死鎖（deadLock）。
  • 從chanel裡面讀數據立馬就會被阻塞，直到有向chanel寫數據的goroutine來。
  • 向chanel裡面寫數據立馬就會被阻塞，直到有從chanel讀數據的goroutine來。

（以上都是相對於沒有緩存的通道而言，後面講到的緩存通道在緩沖區滿的時候才阻塞，而不是立刻阻塞）

以上就是Go通道channel通過通信共享內存的詳細內容，更多關於Go channel通信共享內存的資料請關註WalkonNet其它相關文章！

推薦閱讀：