Golang并发模式之生产者消费者示例-Golang-PHP中文网

Golang并发模式之生产者消费者示例

P粉602998670

发布： 2025-09-14 14:46:01

原创

954人浏览过

生产者消费者模式通过channel实现协程间安全通信，生产者生成数据并发送至channel，消费者接收并处理数据，利用有缓冲channel避免阻塞，生产者关闭channel通知结束，消费者通过range监听，多消费者场景可用WaitGroup或多个done channel协调，适用于任务解耦场景如消息队列，需注意channel关闭、缓冲大小与goroutine泄漏问题。

golang并发模式之生产者消费者示例

在Go语言中，生产者消费者模式是并发编程的经典模型之一。它通过解耦数据生成（生产者）和数据处理（消费者），提升程序的效率与可维护性。该模式通常借助channel来实现协程间的安全通信。

基本概念与核心结构

生产者负责生成数据并发送到channel，消费者从channel接收并处理数据。利用goroutine和channel，Go能轻松实现这一模式。

关键点：

使用有缓冲channel避免生产者阻塞
生产者完成时关闭channel，通知消费者数据结束
消费者通过
```
range
```
登录后复制
监听channel自动感知关闭

简单示例代码

以下是一个基础的生产者消费者实现：

立即学习“go语言免费学习笔记（深入）”；

package main
<p>import (
"fmt"
"time"
)</p><p>func producer(ch chan<- int) {
defer close(ch)
for i := 1; i <= 5; i++ {
ch <- i
fmt.Printf("生产者: 生成数据 %d\n", i)
time.Sleep(500 * time.Millisecond)
}
}</p><p>func consumer(ch <-chan int, done chan<- bool) {
defer func() { done <- true }()
for data := range ch {
fmt.Printf("消费者: 处理数据 %d\n", data)
time.Sleep(800 * time.Millisecond)
}
}</p><p>func main() {
ch := make(chan int, 3)
done := make(chan bool)</p><pre class='brush:php;toolbar:false;'>go producer(ch)
go consumer(ch, done)

<-done

登录后复制

}

多消费者场景优化

实际应用中常需多个消费者并行处理以提高吞吐量。此时需确保所有消费者都完成后主程序再退出。

歌者PPT

歌者PPT，AI 写 PPT 永久免费

197

查看详情

改进方式：

使用
```
sync.WaitGroup
```
登录后复制
管理多个消费者
或通过多个
```
done
```
登录后复制
信号channel统一等待

例如启动3个消费者：

for i := 0; i < 3; i++ {
    go func(id int) {
        for data := range ch {
            fmt.Printf("消费者-%d: 处理 %d\n", id, data)
            time.Sleep(600 * time.Millisecond)
        }
    }(i)
}

登录后复制

主函数中可通过接收多次done信号或使用WaitGroup等待全部完成。