用生产者消费者理解golang channel

golang实现多生产者多消费者:

package main
import (
 "fmt"
 "time"
)
func consumer(cname string, ch chan int) {
 for i := range ch {
 fmt.Println("consumer--", cname, ":", i)
 }
 fmt.Println("ch closed.")
}
func producer(pname string, ch chan int) {
 for i := 0; i < 4; i++ {
 fmt.Println("producer--", pname, ":", i)
 ch <- i
 }
}
func main() {
 //用channel来传递"产品", 不再需要自己去加锁维护一个全局的阻塞队列
 data := make(chan int)
 go producer("生产者1", data)
 go producer("生产者2", data)
 go consumer("消费者1", data)
 go consumer("消费者2", data)
 time.Sleep(10 * time.Second)
 close(data)
 time.Sleep(10 * time.Second)
}

运行结果:

D:/Go/pv/pv.exe [D:/Go/pv]
producer-- 生产者2 : 0
producer-- 生产者2 : 1
producer-- 生产者2 : 2
producer-- 生产者1 : 0
consumer-- 消费者2 : 1
consumer-- 消费者2 : 2
consumer-- 消费者2 : 0
producer-- 生产者1 : 1
producer-- 生产者1 : 2
consumer-- 消费者2 : 1
consumer-- 消费者2 : 2
producer-- 生产者1 : 3
consumer-- 消费者2 : 3
consumer-- 消费者1 : 0
producer-- 生产者2 : 3
consumer-- 消费者2 : 3
ch closed.
ch closed.
成功: 进程退出代码 0.

可以看出,用golang实现生产者消费者非常简单,PV操作不需要各种加锁解锁,奥妙就在于CSP模型,即golang提倡的用通信代替共享内存。

本文来自:简书

感谢作者:zengfan

查看原文:用生产者消费者理解golang channel

• 编辑
• 预览