如何利用 Go 語言進行並發程式設計？-Golang-PHP中文網

如何利用 Go 語言進行並發程式設計？

PHPz

發布： 2023-06-10 10:33:07

原創

958 人瀏覽過

隨著電腦硬體的不斷發展，處理器中的 CPU 核心不再單獨增加時脈頻率，而是增加核心數。這引發了一個顯而易見的問題：如何發揮這些核心的效能？

一種解決方法是透過並行編程，即同時執行多個任務，以充分利用 CPU 核心。這就是 Go 語言的一個獨特之處，它是一門專為並發程式設計而設計的語言。

在本文中，我們將探討如何利用 Go 語言進行並發程式設計。

協程

首先，我們需要了解的是 Go 語言中的一種特殊機制：協程。協程（Coroutine）是一種輕量級線程，可以在一個線程中多次切換執行，實現並行執行。

與作業系統執行緒相比，協程的切換成本非常低。它們由 Go 運行時（runtime）管理，該運行時使用 m:n 的映射方式將 m 個協程映射到 n 個作業系統執行緒上。這使得 Go 語言具有非常高效和穩定的並發執行能力。

在 Go 語言中，可以使用 go 關鍵字來啟動一個協程。例如：

func main() {
    go hello()
}

func hello() {
    fmt.Println("Hello, world!")
}

登入後複製

在上面的程式碼中，hello() 函數將會在一個新的協程中執行。當程式退出 main() 函數時，hello() 函數可能還在執行，因此程式不會立即退出。

通道

協程之間的通訊非常重要，因為它們需要共用資料。 Go 語言中有一種特殊類型的變量，稱為通道（Channel），用於在協程之間傳遞資料。

可以透過 make() 函數建立一個通道，例如：

ch := make(chan int)

登入後複製

上面的程式碼將建立一個整數類型的通道。

資料可以透過通道的傳送和接收操作傳遞。可以使用 <- 運算子對通道進行傳送和接收操作。例如：

ch <- 42 // 发送数据
x := <-ch // 接收数据

登入後複製

<- 運算子可以在左側或右側使用，以用於傳送或接收資料。如果通道是無緩衝的，則傳送操作將阻塞，直到另一個協程接收資料。類似地，如果沒有可用的數據，則接收操作將阻塞。

WaitGroup

在處理多個協程時，可能需要等待它們全部執行完畢。可以使用 sync.WaitGroup 來達成這個目的。例如：

func main() {
    var wg sync.WaitGroup
    wg.Add(2) // 增加计数器

    go func() {
        defer wg.Done() // 完成时减少计数器
        fmt.Println("Hello,")
    }()

    go func() {
        defer wg.Done() // 完成时减少计数器
        fmt.Println("world!")
    }()

    wg.Wait() // 等待协程全部完成
}

登入後複製

在上面的程式碼中，wg 是一個 sync.WaitGroup 對象，包含一個計數器。 Add() 方法會將計數器增加，表示需要等待的協程數。 Done() 方法將計數器減少，表示一個協程已經完成。 Wait() 方法將一直等待，直到計數器為零。

範例

下面是一個範例程序，示範如何利用協程和通道進行並發程式設計：

func main() {
    ch := make(chan int)

    go func() {
        for i := 0; i < 10; i++ {
            ch <- i // 发送数据
        }
        close(ch) // 关闭通道
    }()

    for i := range ch { // 循环接收数据，直到通道关闭
        fmt.Println(i)
    }
}

登入後複製

在上面的程式碼中，我們建立了一個整數類型的通道ch。然後，我們在一個新的協程中向通道發送 0 到 9 的整數。最後，我們使用 range 關鍵字循環接收通道中的數據，並列印出來。

注意，我們在發送所有資料後，透過 close() 方法關閉了通道。這使得循環讀取通道的協程可以退出。