當前位置：首頁 > 科技 > 軟件

深入Go原理：協程間通信基礎Chan

來源：責編：時間：2024-05-29 08:53:54 208觀看

導讀在 Go 語言中，chan（通道）是用于在不同 goroutine 之間進行通信和同步的重要機制。它的設計和實現允許在并發編程中安全、有效地傳遞數據。以下是 chan 的工作原理和實現細節基本概念通道類型通道有類型，指定了通道能夠傳

在 Go 語言中，chan（通道）是用于在不同 goroutine 之間進行通信和同步的重要機制。它的設計和實現允許在并發編程中安全、有效地傳遞數據。以下是 chan 的工作原理和實現細節

基本概念

通道類型

通道有類型，指定了通道能夠傳遞的數據類型。例如，chan int 是一個只能傳遞整數的通道。

無緩沖通道

沒有緩沖區的通道，發送和接收操作是同步的，即發送操作會阻塞直到有接收操作發生。

有緩沖通道

具有一定緩沖區的通道，發送操作在緩沖區未滿時不會阻塞，直到緩沖區滿時才會阻塞。

通道的內部結構

通道在內部是通過 hchan 結構體來實現的。這個結構體包含了通道的基本信息和狀態

type hchan struct {    qcount   uint           // 緩沖區中數據的數量    dataqsiz uint           // 緩沖區的大小    buf      unsafe.Pointer // 緩沖區指針    elemsize uint16         // 元素的大小    closed   uint32         // 通道是否關閉    sendx    uint           // 發送操作的索引    recvx    uint           // 接收操作的索引    recvq    waitq          // 等待接收的 goroutine 隊列    sendq    waitq          // 等待發送的 goroutine 隊列    lock     mutex          // 保護通道的互斥鎖}

發送和接收操作

無緩沖通道

發送操作

如果沒有接收者，發送方會阻塞，直到有接收方開始接收。

接收操作

如果沒有發送者，接收方會阻塞，直到有發送方開始發送。

有緩沖通道

發送操作

如果緩沖區未滿，數據直接寫入緩沖區。若緩沖區已滿，發送方會阻塞，直到有空間可用。

接收操作

如果緩沖區不為空，數據直接從緩沖區讀取。若緩沖區為空，接收方會阻塞，直到有數據可讀。

通道的同步機制

通道的發送和接收操作都是原子性的，并且由互斥鎖保護。這確保了多個 goroutine 同時操作通道時不會發生競態條件。

互斥鎖（Mutex）

每個通道都有一個互斥鎖，用于保護通道的狀態和數據。

等待隊列（Wait Queue）

通道維護兩個等待隊列，一個用于等待接收的 goroutine，一個用于等待發送的 goroutine。當發送或接收操作不能立即完成時，goroutine 會被加入相應的等待隊列中。

通道關閉

關閉通道

通過調用 close(chan) 可以關閉通道。關閉操作會設置通道的 closed 標志，并喚醒所有在通道上阻塞的發送和接收操作。

關閉后的操作

向已關閉的通道發送數據會引發 panic，從已關閉的通道接收數據會立即返回零值。

實現細節

以下是通道發送和接收操作的一些實現細節

發送操作

chan send 檢查通道是否關閉，如果沒有接收者且緩沖區未滿，數據會被直接寫入緩沖區，否則會阻塞當前 goroutine 并將其加入 sendq。

接收操作

chan recv 檢查通道是否關閉或緩沖區是否為空，如果有數據則直接返回，否則阻塞當前 goroutine 并將其加入 recvq。

總結

Go 語言中的通道通過上述機制實現了 goroutine 之間的安全、高效通信。通道的設計考慮了并發編程中的同步問題，通過緩沖機制和等待隊列的管理，使得數據傳遞和同步操作都能高效地進行。

例子

在 Go 語言中，可以通過 make 函數來定義通道。根據是否指定緩沖區大小，可以創建無緩沖區通道和有緩沖區通道。以下是具體的定義和示例：

無緩沖區通道

無緩沖區通道是指在沒有緩沖區的情況下，發送和接收操作是同步的。發送操作會一直阻塞，直到有接收者接收數據。

定義無緩沖區通道

ch := make(chan int)

示例

package mainimport (    "fmt")func main() {    ch := make(chan int)    // 啟動一個 goroutine 發送數據    go func() {        ch <- 42 // 發送操作會阻塞，直到有接收者    }()    // 接收數據    value := <-ch    fmt.Println(value) // 輸出: 42}

在這個例子中，ch 是一個無緩沖區通道，發送操作 ch <- 42 會阻塞，直到主 goroutine 執行 <-ch 接收數據。

有緩沖區通道

有緩沖區通道允許在緩沖區未滿時發送操作不會阻塞，直到緩沖區滿時才會阻塞。

定義有緩沖區通道

ch := make(chan int, 3) // 創建一個緩沖區大小為 3 的通道

示例

package mainimport (    "fmt")func main() {    ch := make(chan int, 3) // 定義緩沖區大小為 3 的通道    // 發送數據到通道，不會阻塞    ch <- 1    ch <- 2    ch <- 3    // 緩沖區已滿，下面的發送操作會阻塞，直到有接收者    go func() {        ch <- 4    }()    // 接收數據    fmt.Println(<-ch) // 輸出: 1    fmt.Println(<-ch) // 輸出: 2    fmt.Println(<-ch) // 輸出: 3    fmt.Println(<-ch) // 輸出: 4}

在這個例子中，ch 是一個有緩沖區通道，緩沖區大小為 3。前 3 個發送操作不會阻塞，直到緩沖區滿后，第 4 個發送操作會阻塞，直到有接收者開始接收數據。

總結

通過 make(chan T) 可以創建無緩沖區通道，通過 make(chan T, capacity) 可以創建有緩沖區通道。無緩沖區通道在發送和接收操作上是同步的，而有緩沖區通道允許在緩沖區未滿時進行非阻塞的發送操作。通過以上示例，可以清晰地看到兩種通道的行為差異。

select

在 Go 語言中，select 語句用于處理多個通道的通信操作。它的作用是讓 goroutine 可以同時等待多個通道操作（發送或接收），并在其中任何一個通道操作完成時執行相應的分支代碼。select 語句的使用使得在處理并發編程時更加靈活和高效。

select 語句的基本用法

select 語句的語法與 switch 語句類似，但它專門用于通道操作。每個 case 分支包含一個通道操作（發送或接收），select 會選擇其中一個已準備好的通道操作進行處理。

語法結構

select {case expr1:    // 如果 expr1 通道操作可以進行，則執行此分支case expr2:    // 如果 expr2 通道操作可以進行，則執行此分支default:    // 如果沒有任何通道操作可以進行，則執行此分支}

示例：使用 select 同時等待多個通道操作

以下是一個使用 select 語句的示例：

package mainimport (    "fmt"    "time")func main() {    ch1 := make(chan string)    ch2 := make(chan string)    // 啟動第一個 goroutine    go func() {        time.Sleep(2 * time.Second)        ch1 <- "message from ch1"    }()    // 啟動第二個 goroutine    go func() {        time.Sleep(1 * time.Second)        ch2 <- "message from ch2"    }()    for i := 0; i < 2; i++ {        select {        case msg1 := <-ch1:            fmt.Println(msg1)        case msg2 := <-ch2:            fmt.Println(msg2)        }    }}

在這個例子中，有兩個通道 ch1 和 ch2，每個通道都在不同的 goroutine 中發送消息。select 語句使得主 goroutine 可以同時等待兩個通道的消息，并在任意一個通道接收到消息時執行相應的分支。

default 分支

如果在 select 語句中添加了 default 分支，當所有通道操作都無法立即進行時，會執行 default 分支。這樣可以避免 select 語句阻塞。

示例：帶有 default 分支的 select

package mainimport (    "fmt"    "time")func main() {    ch := make(chan string)    go func() {        time.Sleep(2 * time.Second)        ch <- "message"    }()    for {        select {        case msg := <-ch:            fmt.Println(msg)            return        default:            fmt.Println("No message received, doing other work")            time.Sleep(500 * time.Millisecond)        }    }}

在這個例子中，如果通道 ch 上沒有消息可接收，select 會執行 default 分支，打印一條消息并繼續執行其他工作。

總結

select 語句是 Go 語言中處理并發編程的重要工具，通過它可以同時等待多個通道操作并在其中一個操作完成時進行相應處理。select 提供了一種靈活且高效的方式來處理多個通道之間的通信，使得并發程序的設計更加簡潔和直觀。

等待多個通道的邏輯

在 Go 語言的 select 語句中，如果有多個通道操作同時準備就緒（即都可以進行），Go 運行時會從這些通道操作中隨機選擇一個執行。一旦某個通道操作被選中并執行，其它通道的等待操作將不會繼續進行。每次執行 select 語句時都會重新評估所有通道操作。

示例：多個通道同時就緒

為了更好地理解這個機制，以下是一個示例，展示當多個通道同時準備就緒時，select 語句的行為：

package mainimport (    "fmt"    "time")func main() {    ch1 := make(chan string)    ch2 := make(chan string)    ch3 := make(chan string)    go func() {        time.Sleep(1 * time.Second)        ch1 <- "message from ch1"    }()    go func() {        time.Sleep(1 * time.Second)        ch2 <- "message from ch2"    }()    go func() {        time.Sleep(1 * time.Second)        ch3 <- "message from ch3"    }()    for i := 0; i < 3; i++ {        select {        case msg1 := <-ch1:            fmt.Println(msg1)        case msg2 := <-ch2:            fmt.Println(msg2)        case msg3 := <-ch3:            fmt.Println(msg3)        }    }}

在這個示例中，有三個通道 ch1, ch2, 和 ch3，每個通道在 1 秒后發送一個消息。因為所有通道在同一時間準備就緒，select 語句將從中隨機選擇一個進行處理，并打印相應的消息。每次循環都會重新評估所有通道。

結論

當 select 語句等待多個通道時，如果其中一個通道操作可以進行，其它通道的操作不會繼續等待，而是等待下一次 select 語句的評估。每次 select 語句執行時都會重新評估所有通道操作，并選擇其中一個可以進行的操作。如果多個通道同時就緒，select 會隨機選擇其中一個進行處理。

本文鏈接：http://m.www897cc.com/showinfo-26-91354-0.html深入Go原理：協程間通信基礎Chan

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com

上一篇： SpringBoot優雅定制接口參數格式轉換

下一篇： SpringBoot的自動裝配，你學會了嗎？

標簽：

熱門焦點

影音體驗是真的強簡單聊聊iQOO Pad

大公司的好處就是產品線豐富，非常細分化的東西也能給你做出來，例如早先我們看到了新的vivo Pad2，之后我們又在iQOO Neo8 Pro的發布會上看到了iQOO的首款平板產品iQOO Pad。雖
天貓精靈Sound Pro體驗：智能音箱沒有音質？來聽聽我的

這幾年除了手機作為智能生活終端最主要的核心之外，第二個可以成為中心點的產品是什么？——是智能音箱。手機在執行命令的時候有兩種操作方式，手和智能語音助手，而智能音箱只
7月安卓手機性價比榜：努比亞+紅魔兩款新機入榜

7月登場的新機有努比亞Z50S Pro和紅魔8S Pro，除了三星之外目前唯二的兩款搭載超頻版驍龍8Gen2處理器的產品，而且努比亞和紅魔也一貫有著不錯的性價比，所以在本次的性價比榜單
太卷！Redmi MAX 100英寸電視便宜了：12999元買Redmi史上最大屏

8月5日消息，從小米商城了解到，Redmi MAX 100英寸巨屏電視日前迎來官方優惠，到手價12999元，比發布價便宜了7000元，在大屏電視市場開卷。據了解，Redmi MAX 100
猿輔導與新東方的兩種“歸途”

作者｜卓心月出品｜零態LT（ID：LingTai_LT）如何成為一家偉大企業？答案一定是對“勢”的把握，這其中最關鍵的當屬對企業戰略的制定，且能夠站在未來看現在，即使這其中的
華為Mate60系列模具曝光：采用碩大圓形后置相機模組+拼接配色方案

據此前多方爆料，今年華為將開始恢復一年雙旗艦戰略，除上半年推出的P60系列外，往年下半年的Mate系列也將迎來更新，有望在9-10月份帶來全新的華為Mate60
三星Galaxy Z Fold5官方渲染圖曝光：13.4mm折疊厚度依舊感人

據官方此前宣布，三星將于7月26日在韓國首爾舉辦Unpacked活動，屆時將帶來帶來包括Galaxy Buds 3、Galaxy Watch 6、Galaxy Tab S9、Galaxy Z Flip 5、
最薄的14英寸游戲筆記本電腦 Alienware X14已可以購買

2022年1月份在國際消費電子展(CES2022)上首次亮相的Alienware新品——Alienware X14現在已經可以購買了，這款筆記本電腦被譽為世界上最薄的 14 英寸游戲筆
北京：科技教育體驗基地開始登記

　　北京“科技館之城”科技教育體驗基地登記和認證工作日前啟動。首批北京科技教育體驗基地擬于2023年全國科普日期間掛牌，后續還將開展常態化登記。　　北京科技教育體驗基

深入Go原理：協程間通信基礎Chan

基本概念

通道類型

無緩沖通道

有緩沖通道

通道的內部結構

發送和接收操作

無緩沖通道

發送操作

接收操作

有緩沖通道

發送操作

接收操作

通道的同步機制

互斥鎖（Mutex）

等待隊列（Wait Queue）

通道關閉

關閉通道

關閉后的操作

實現細節

發送操作

接收操作

總結

例子

無緩沖區通道

定義無緩沖區通道

示例

有緩沖區通道

定義有緩沖區通道

示例

總結

select

select 語句的基本用法

語法結構

示例：使用 select 同時等待多個通道操作

default 分支

示例：帶有 default 分支的 select

總結

等待多個通道的邏輯

示例：多個通道同時就緒

結論

最新推薦

猜你喜歡

熱門推薦

相關資訊