Golangchannel生产者消费者示例详解

积累知识，胜过积蓄金银！毕竟在Golang开发的过程中，会遇到各种各样的问题，往往都是一些细节知识点还没有掌握好而导致的，因此基础知识点的积累是很重要的。下面本文《Golang channel实现生产者消费者示例》，就带大家讲解一下知识点，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

Go语言中channel是实现生产者消费者模式的核心工具，通过goroutine与channel协作实现并发任务处理；示例中3个生产者向带缓冲channel发送数据，2个消费者从中接收并处理，使用WaitGroup同步并由单独goroutine在生产结束后关闭channel，消费者通过range自动退出，整个过程线程安全且无需显式锁，适用于任务分发等场景。

在Go语言中，channel 是实现生产者消费者模式的天然工具。它通过 goroutine 和 channel 的协作，能够简洁高效地完成并发任务处理。下面是一个典型的生产者消费者模式示例，展示如何使用 channel 在多个生产者和消费者之间传递数据。

基本结构说明

在这个模式中：

• 生产者（Producer）：向 channel 发送数据
• 消费者（Consumer）：从 channel 接收并处理数据
• channel：作为协程间通信的管道

完整代码示例

package main
import (
"fmt"
"math/rand"
"sync"
"time"
)
// 生产者函数
func producer(id int, dataChan chan<- int, wg sync.WaitGroup) {
defer wg.Done()
for i := 0; i < 5; i++ {
num := rand.Intn(100)
dataChan <- num
fmt.Printf("生产者 %d 生成: %d\n", id, num)
time.Sleep(time.Millisecond  100)
}
}
// 消费者函数
func consumer(id int, dataChan <-chan int, wg sync.WaitGroup) {
defer wg.Done()
for num := range dataChan {
fmt.Printf("消费者 %d 处理: %d\n", id, num)
time.Sleep(time.Millisecond  150) // 模拟处理时间
}
}
func main() {
// 创建带缓冲的channel，容量为10
dataChan := make(chan int, 10)
var wg sync.WaitGroup

// 启动3个生产者
for i := 1; i <= 3; i++ {
    wg.Add(1)
    go producer(i, dataChan, &wg)
}

// 启动2个消费者
for i := 1; i <= 2; i++ {
    wg.Add(1)
    go consumer(i, dataChan, &wg)
}

// 等待所有生产者完成
go func() {
    wg.Wait()
    close(dataChan) // 所有生产者结束后关闭channel
}()

// 等待所有消费者完成（消费者会在channel关闭后自动退出）
wg.Wait()
fmt.Println("所有任务完成")
}

关键点解析

• 带缓冲 channel：make(chan int, 10) 提供缓冲，避免生产者阻塞
• 只发送/只接收 channel：dataChan <-chan int 限制操作方向，增强类型安全
• goroutine 同步：使用 sync.WaitGroup 确保所有生产者执行完毕
• 关闭 channel：由单独的 goroutine 在生产者全部结束后关闭 channel，触发消费者退出
• range 遍历 channel：消费者用 for-range 自动接收数据，channel 关闭后循环结束

运行效果

程序会输出类似以下内容：

生产者并发生成数据，消费者从共享队列中取数据处理，整个过程线程安全且无需显式加锁。

基本上就这些。这种模式适用于日志收集、任务分发、消息队列等场景，是Go并发编程的经典实践。

今天关于《Golangchannel生产者消费者示例详解》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！