Golang函數並發程式設計中的緩衝通道使用方法

緩衝通道是 Go 函數並發程式設計中安全傳遞資料的有效方法。它們會建立一個固定大小的緩衝區來儲存待發送或接收的資料。使用 make 建立緩衝通道，指定容量。生產者 goroutine 使用 chan

Go 語言函數並發程式設計中的緩衝通道用法

緩衝通道在Go 語言函數並發程式設計中非常有用，它允許在goroutine 之間安全地傳遞資料。它透過建立一個固定大小的緩衝區來實現，該緩衝區儲存待發送或接收的資料。

建立緩衝通道

bufferedChannel := make(chan int, 10)

這裡的 10 表示緩衝區的容量，它可以儲存最多 10 個整數。

goroutine 間的通訊

生產者goroutine 可以使用chan<- 運算子向通道傳送資料：

go func() {
    bufferedChannel <- 42
}()

消費者goroutine 可以使用<-chan 運算子從通道接收資料：

go func() {
    fmt.Println(<-bufferedChannel)
}()

實戰案例

為了示範緩衝通道的用法，讓我們編寫一個簡單的程序，它從生產者goroutine 產生隨機數，並將其傳遞給消費者goroutine 進行列印。

程式碼如下：

package main

import (
    "fmt"
    "math/rand"
    "sync"
)

func main() {
    // 创建一个缓冲通道
    bufferedChannel := make(chan int, 10)

    // 生成随机数的 goroutine
    go func() {
        for i := 0; i < 100; i++ {
            bufferedChannel <- rand.Intn(100)
        }
        close(bufferedChannel) // 发送完成后关闭通道
    }()

    // 打印随机数的 goroutine
    var wg sync.WaitGroup
    wg.Add(1)
    go func() {
        defer wg.Done()
        for {
            value, ok := <-bufferedChannel
            if !ok {
                return // 通道已关闭
            }
            fmt.Println(value)
        }
    }()

    wg.Wait() // 等待消费者 goroutine 结束
}

在這個範例中，我們將緩衝區的容量設為10，這表示生產者goroutine 可以並行產生10 個隨機數，而無需阻塞。消費者 goroutine 循環從通道接收隨機數，直到通道關閉為止。

以上是Golang函數並發程式設計中的緩衝通道使用方法的詳細內容。更多資訊請關注PHP中文網其他相關文章！