Go并发编程实战：从基础到实战案例解析

在Go语言中，并发编程通常使用goroutines和channels来实现。下面是一个简单的并发编程示例，其中使用了goroutines和channels来并行处理任务和通信。

package main
 
import (
    "fmt"
    "sync"
    "time"
)
 
func worker(id int, wg *sync.WaitGroup, jobs <-chan int, results chan<- int) {
    defer wg.Done() // 确保该goroutine在结束时通知WaitGroup
    for job := range jobs {
        // 模拟耗时工作
        time.Sleep(time.Second)
        fmt.Println("Worker", id, "processing job", job)
        results <- job * 2 // 将处理后的结果发送到results通道
    }
}
 
func main() {
    var wg sync.WaitGroup
    jobs := make(chan int, 100) // 创建一个缓冲为100的jobs通道
    results := make(chan int, 100) // 创建一个缓冲为100的results通道
 
    // 启动worker数量
    workerCount := 3
    wg.Add(workerCount)
 
    for i := 0; i < workerCount; i++ {
        go worker(i, &wg, jobs, results) // 创建goroutine执行worker函数
    }
 
    // 发送作业并关闭通道
    go func() {
        for i := 0; i < 10; i++ {
            jobs <- i
        }
        close(jobs) // 所有作业发送完毕，关闭作业通道
    }()
 
    // 收集结果
    go func() {
        for result := range results {
            fmt.Println("Result:", result)
        }
        close(results) // 收集完所有结果，关闭结果通道
    }()
 
    wg.Wait() // 等待所有goroutines完成
}

这段代码定义了一个worker函数，它接收一个ID、一个WaitGroup、一个作业通道和一个结果通道。每个worker循环从作业通道接收作业，处理后将结果发送到结果通道。main函数中，我们启动了三个worker goroutines，并发送了10个作业。最后，我们使用WaitGroup来等待所有的goroutines完成工作。

这个例子展示了Go语言中并发编程的基本概念，并通过实际的代码演示了如何使用goroutines和channels来实现任务的并行处理和结果的同步收集。