GO语言初级学习之代码案例08-生产者消费者模型
@(go语言 黑马)[GO语言]
条件变量模拟生产者消费者模型
- 题目：有5个消费者，5个生产者，仓库容量为5个；生产者不断生产物品在仓库中，消费者不断往仓库中消费物品，保证消费者想消费时仓库里有东西，生产者生产的物品有地方放置；
- 知识点：通道channel，互斥锁，go并发，条件变量
- 逻辑：
_1. 分别设计好单个生产者、消费者，分别实现 持续 生产、消费功能
_2. 搭建仓库，并使生产者、消费者分别从仓库中生产消费
_3. 为了使仓库不拥堵、不空荡荡，分别加上条件限制：仓库满了生产者停止生产，空出空间后恢复生产；仓库空了消费者停止消费，有货物后恢复消费
_4. 加上go程，生产者、消费者分别各加上五个go程]
- 代码如下：
package main
import "fmt"
func init() {
rand.Seed(time.Now().UnixNano())
}
var cond01 sync.Cond//条件变量
func main() {
ch := make(chan int, 5) // 通道模拟仓库,容量为5
cond01.L = new(sync.Mutex)// cond01.L是一个互斥锁，使用前需要开辟一个互斥锁空间
//十个go程，五个生产者，五个消费者
for i := 0; i < 5; i++ {
go producer01(ch, i)
}
for i := 0; i < 5; i++ {
go comsumer01(ch, i)
}
for {
;
}
}
func producer01(ch chan int, idx int) {
for {// for循环让改生产者持续生产下去
cond01.L.Lock()//保证该生产者完成了本次生产，才释放CPU，生产的产品不会被覆盖
for len(ch) == 5 {
cond01.Wait()// 当仓库中满了时，停止生产，直到消费者消费唤醒，cond01.Wait()可被cond01.Signal()唤醒
}
product := rand.Intn(100)//随机数模拟产品
ch <- product
fmt.Printf("---第%d生产者，生产：%d\n", idx, product)
time.Sleep(200*time.Millisecond)
cond01.Signal()
cond01.L.Unlock()//解锁
}
}
func comsumer01(ch chan int, idx int) {
for {// for循环让改消费者持续消费下去
cond01.L.Lock()
for len(ch) == 0 {
cond01.Wait()
}
gift := <-ch//读数据模拟消费产品
fmt.Printf("第%d消费者，消费：%d\n", idx, gift)
time.Sleep(200*time.Millisecond)
cond01.Signal()
cond01.L.Unlock()
}
}
