利用Go Channels構建同步模式

在Go語言中，可以使用Channels來實現同步模式。Channels是一種在Go語言中用來進行并發通信的數據結構，可以在多個goroutine之間傳遞數據。通過使用Channels，可以實現goroutine之間的同步操作。

下面是一個簡單的例子，展示了如何使用Channels構建同步模式：

package main

import (
    "fmt"
    "sync"
)

func worker(id int, jobs <-chan int, results chan<- int, wg *sync.WaitGroup) {
    defer wg.Done()
    for j := range jobs {
        fmt.Printf("Worker %d processing job %d\n", id, j)
        results <- j * 2
    }
}

func main() {
    numJobs := 5
    numWorkers := 3

    jobs := make(chan int, numJobs)
    results := make(chan int, numJobs)
    var wg sync.WaitGroup

    for i := 1; i <= numWorkers; i++ {
        wg.Add(1)
        go worker(i, jobs, results, &wg)
    }

    for j := 1; j <= numJobs; j++ {
        jobs <- j
    }
    close(jobs)

    wg.Wait()

    for r := 1; r <= numJobs; r++ {
        fmt.Printf("Result %d: %d\n", r, <-results)
    }
}

在這個例子中，我們首先創建了兩個Channels，一個用來傳遞任務(jobs)，另一個用來傳遞結果(results)。然后我們創建了多個worker goroutine，并通過WaitGroup來等待它們完成任務。每個worker goroutine從jobs Channel中接收任務，處理后將結果發送到results Channel中。最后主goroutine從results Channel中讀取結果并輸出。

通過使用Channels和WaitGroup，我們可以實現goroutine之間的同步操作，確保它們按照預期的順序執行。這種同步模式可以有效地控制并發操作，避免出現競態條件和數據競爭。