Go语言中channel是实现生产者消费者模式的核心工具，通过goroutine与channel协作实现并发任务处理；示例中3个生产者向带缓冲channel发送数据，2个消费者从中接收并处理，使用WaitGroup同步并由单独goroutine在生产结束后关闭channel，消费者通过range自动退出，整个过程线程安全且无需显式锁，适用于任务分发等场景。
在Go语言中，channel 是实现生产者消费者模式的天然工具。它通过 goroutine 和 channel 的协作，能够简洁高效地完成并发任务处理。下面是一个典型的生产者消费者模式示例，展示如何使用 channel 在多个生产者和消费者之间传递数据。
基本结构说明
在这个模式中：
生产者（Producer）：向 channel 发送数据消费者（Consumer）：从 channel 接收并处理数据channel：作为协程间通信的管道
完整代码示例
package mainimport ("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 <- numfmt.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，容量为10dataChan := 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 关闭后循环结束
运行效果
程序会输出类似以下内容：
腾讯AI Lab开发的AI写作助手，提升写作者的写作效率和创作体验
立即学习“go语言免费学习笔记（深入）”；
生产者 1 生成: 42
生产者 2 生成: 78
消费者 1 处理: 42
生产者 3 生成: 15
消费者 2 处理: 78
...生产者并发生成数据，消费者从共享队列中取数据处理，整个过程线程安全且无需显式加锁。
基本上就这些。这种模式适用于日志收集、任务分发、消息队列等场景，是Go并发编程的经典实践。
以上就是Golangchannel实现生产者消费者模式示例的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1100498.html
微信扫一扫 
支付宝扫一扫 
