佳实践\n \n\n适合读者：\n\n* Go 语言开发者\n \n* 对并发编程感兴趣的程序员\n \n* 需要优化并发性能的工程师\n \n\n目录\n--\n\n1. 基础概念\n \n2. 核心并发模式\n \n3. 并发安全模式\n \n4. 性能对比\n \n5. 最佳实践\n \n6. 常见陷阱\n \n7. 实战案例分析\n \n8. 监控和调试\n \n9. 部署注意事项\n \n\n1\\. 基础概念\n--------\n\nGo 语言以其强大的并发特性而闻名，它提供了简单而优雅的并发编程模式。本文将详细介绍 Go 中常见的并发模式及其实践应用。\n\n### 1.1 Goroutine 基础\n\nGoroutine 是 Go 的轻量级线程，创建成本极低。基本使用方式：\n\n```\nfunc main() { \n go func() { \n // 并发执行的代码 \n fmt.Println(\"在新的 goroutine 中执行\") \n }() \n // 主线程代码 \n time.Sleep(time.Second) \n} \n```\n\n### 1.2 Channel 通信\n\nChannel 是 Go 中 goroutine 之间通信的主要方式：\n\n```\nfunc producer(ch chan<- int) { \n for i := 0; i < 5; i++ { \n ch <- i // 发送数据 \n } \n close(ch) \n} \n \nfunc consumer(ch <-chan int) { \n for num := range ch { // 接收数据 \n fmt.Println(\"received:\", num) \n } \n} \n```\n\n2\\. 核心并发模式\n----------\n\n### 2.1 生产者-消费者模式\n\n这是最常见的并发模式之一：\n\n```\nfunc ProducerConsumer() { \n queue := make(chan int, 10) \n \n // 生产者 \n go func() { \n for i := 0; i < 100; i++ { \n queue <- i \n } \n close(queue) \n }() \n \n // 消费者 \n for item := range queue { \n fmt.Println(\"Processing:\", item) \n } \n} \n```\n\n### 2.2 扇出模式（Fan-out）\n\n将工作分配给多个 worker：\n\n```\nfunc FanOut(work []int, workers int) { \n jobs := make(chan int) \n \n // 启动 workers \n for i := 0; i < workers; i++ { \n go func(id int) { \n for job := range jobs { \n fmt.Printf(\"Worker %d processing job %d\\n\", id, job) \n } \n }(i) \n } \n \n // 分发工作 \n for _, job := range work { \n jobs <- job \n } \n close(jobs) \n} \n```\n\n### 2.3 扇入模式（Fan-in）\n\n合并多个输入源：\n\n```\nfunc FanIn(inputs ...<-chan int) <-chan int { \n output := make(chan int) \n var wg sync.WaitGroup \n \n // 为每个输入启动一个 goroutine \n for _, input := range inputs { \n wg.Add(1) \n go func(ch <-chan int) { \n defer wg.Done() \n for val := range ch { \n output <- val \n } \n }(input) \n } \n \n // 当所有输入处理完毕后关闭输出 \n go func() { \n wg.Wait() \n close(output) \n }() \n \n return output \n} \n```\n\n### 2.4 超时控制模式\n\n使用 select 实现超时控制：\n\n```\nfunc TimeoutPattern(ch chan int) (int, error) { \n select { \n case result := <-ch: \n return result, nil \n case <-time.After(2 * time.Second): \n return 0, errors.New(\"operation timed out\") \n } \n} \n```\n\n### 2.5 取消操作模式\n\n使用 context 实现可取消的操作：\n\n```\nfunc CancellableOperation(ctx context.Context) error { \n for { \n select { \n case <

Go语言并发模式实战指南

Podcast Information

Roles

Scripts