链接：http://www.jianshu.com/p/d5d246936c62

來源：简书

共 18755分钟

生产者消费者问题是一个著名的线程同步问题，该问题描述如下：有一个生产者在生产产品，这些产品将提供给若干个消费者去消费，为了使生产者和消费者能并发执行，在两者之间设置一个具有多个缓冲区的缓冲池，生产者将它生产的产品放入一个缓冲区中，消费者可以从缓冲区中取走产品进行消费，显然生产者和消费者之间必须保持同步，即不允许消费者到一个空的缓冲区中取产品，也不允许生产者向一个已经放入产品的缓冲区中再次投放产品。

golang 的channel天生具有这种特性，即

  1. 缓冲区满时写，缓冲区空时读，都会阻塞。

  2. channel 本身就是并发安全的。

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

package mainimport ( "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 : 0producer-- 生产者2 : 1producer-- 生产者2 : 2producer-- 生产者1 : 0consumer-- 消费者2 : 1consumer-- 消费者2 : 2consumer-- 消费者2 : 0producer-- 生产者1 : 1producer-- 生产者1 : 2consumer-- 消费者2 : 1consumer-- 消费者2 : 2producer-- 生产者1 : 3consumer-- 消费者2 : 3consumer-- 消费者1 : 0producer-- 生产者2 : 3consumer-- 消费者2 : 3ch closed.ch closed.成功: 进程退出代码 0.