如題，使用條件變量Cond和channel通道實現多個生產者和消費者模型。Go語言天生帶有C語言的基因，很多東西和C與很像，但是用起來 絕對比C語言方便。今天用Go語言來實現下多消費者和生產者模型。如果對C語言的多生產者和消費者模型感興趣的可以看Linux系統編程：使用mutex互斥鎖和條件變量實現多個生成者和消費者模型

代碼實現

代碼實現用了Cond條件變量和channel通道。

package mainimport ("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 <- numfmt.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 := <-infmt.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 }

運行效果

總結

以上是生活随笔為你收集整理的Go语言编程：使用条件变量Cond和channel通道实现多个生产者和消费者模型的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。