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

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

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

導讀在 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://www.tebozhan.com/showinfo-26-91354-0.html深入Go原理：協程間通信基礎Chan

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

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

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

標簽：

熱門焦點

K6：面向開發人員的現代負載測試工具

K6 是一個開源負載測試工具，可以輕松編寫、運行和分析性能測試。它建立在 Go 和 JavaScript 之上，它被設計為功能強大、可擴展且易于使用。k6 可用于測試各種應用程序，包括 Web
一文看懂為蘋果Vision Pro開發應用程序

譯者 | 布加迪審校 | 重樓蘋果的Vision Pro是一款混合現實（MR）頭戴設備。Vision Pro結合了虛擬現實（VR）和增強現實（AR）的沉浸感。其高分辨率顯示屏、先進的傳感器和強大的處理能力
一篇文章帶你了解 CSS 屬性選擇器

屬性選擇器對帶有指定屬性的 HTML 元素設置樣式。可以為擁有指定屬性的 HTML 元素設置樣式，而不僅限于 class 和 id 屬性。一、了解屬性選擇器CSS屬性選擇器提供了一種簡單而
WebRTC.Net庫開發進階，教你實現屏幕共享和多路復用！

WebRTC.Net庫：讓你的應用更親民友好，實現視頻通話無痛接入！除了基本用法外，還有一些進階用法可以更好地利用該庫。自定義 STUN/TURN 服務器配置WebRTC.Net 默認使用 Google 的
中國家電海外掘金正當時｜出海專題

作者｜吳南南編輯｜胡展嘉運營｜陳佳慧出品｜零態LT（ID：LingTai_LT）2023年，出海市場戰況空前，中國創業者在海外紛紛摩拳擦掌，以期能夠把中國的商業模式、創業理念、戰略打法輸出海外，他們依
重估百度丨大模型，能撐起百度的“今天”嗎?

自象限原創作者｜程心羅輯2023年之前，對于自己的“今天”，百度也很迷茫。“新業務到 2022 年底還是 0，希望 2023 年出來一個 1。”這是2022年底，李彥宏
疑似小米14外觀設計圖曝光：后置相機模組變化不大

下半年的大幕已經開啟，而誰將成為下半年手機圈的主角就成為了大家關注的焦點，其中被傳有望拿下新一代驍龍8 Gen3旗艦芯片的小米14系列更是備受大家矚
iQOO Neo8 Pro搶先上架：首發天璣9200+ 安卓性能之王

經過了一段時間的密集爆料，昨日iQOO官方如期對外宣布：將于5月23日推出全新的iQOO Neo8系列新品，官方稱這是一款擁有旗艦級性能調校的作品。隨著發布時
榮耀Magicbook V 14 2021曙光藍版本正式開售，擁有觸摸屏

榮耀 Magicbook V 14 2021 曙光藍版本正式開售，搭載 i7-11390H 處理器與 MX450 顯卡，配備 16GB 內存與 512GB SSD，重 1.48kg，厚 14.5mm，具有 1.5mm 鍵盤鍵程、

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

基本概念

通道類型

無緩沖通道

有緩沖通道

通道的內部結構

發送和接收操作

無緩沖通道

發送操作

接收操作

有緩沖通道

發送操作

接收操作

通道的同步機制

互斥鎖（Mutex）

等待隊列（Wait Queue）

通道關閉

關閉通道

關閉后的操作

實現細節

發送操作

接收操作

總結

例子

無緩沖區通道

定義無緩沖區通道

示例

有緩沖區通道

定義有緩沖區通道

示例

總結

select

select 語句的基本用法

語法結構

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

default 分支

示例：帶有 default 分支的 select

總結

等待多個通道的邏輯

示例：多個通道同時就緒

結論

最新推薦

猜你喜歡

熱門推薦

相關資訊