如题，使用条件变量Cond和channel通道实现多个生产者和消费者模型。Go语言天生带有C语言的基因，很多东西和C与很像，但是用起来 绝对比C语言方便。今天用Go语言来实现下多消费者和生产者模型。如果对C语言的多生产者和消费者模型感兴趣的可以看Linux系统编程：使用mutex互斥锁和条件变量实现多个生成者和消费者模型

代码实现

代码实现用了Cond条件变量和channel通道。

package main

import (
	"fmt"
	"math/rand"
	"sync"
	"time"
)

var cond sync.Cond

//生产者
func produce(out chan<- int, nu int) {
	for {
		cond.L.Lock()
		//产品区满 等待消费者消费
		for len(out) == 3 {
			cond.Wait()
		}
		num := rand.Intn(1000)
		out <- num
		fmt.Printf("%dth ***producer produce***,num = %d,len(chan) = %d\n", nu, num, len(out))
		cond.L.Unlock()

		//生产了产品唤醒 消费者线程
		cond.Signal()
		//生产完了歇一会，给其他协程机会
		time.Sleep(time.Second)
	}
}

//消费者
func consume(in <-chan int, nu int) {
	for {
		cond.L.Lock()
		//产品区空 等待生产者生产
		for len(in) == 0 {
			cond.Wait()
		}
		num := <-in
		fmt.Printf("%dth ###consumer consume###,num = %d,len(chan) = %d\n", nu, num, len(in))
		cond.L.Unlock()
		cond.Signal()

		//消费完了歇一会，给其他协程机会
		time.Sleep(time.Millisecond * 500)
	}
}

func main() {
	//设置随机数种子
	rand.Seed(time.Now().UnixNano())
	quit := make(chan bool)
	//产品区 使用channel模拟
	product := make(chan int, 3)

	//创建互斥锁和条件变量
	cond.L = new(sync.Mutex)

	//5个消费者
	for i := 0; i < 5; i++ {
		go produce(product, i)
	}
	//3个生产者
	for i := 0; i < 3; i++ {
		go consume(product, i)
	}

	//主协程阻塞 不结束
	<-quit
}

运行效果