利用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之间的同步操作，确保它们按照预期的顺序执行。这种同步模式可以有效地控制并发操作，避免出现竞态条件和数据竞争。