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()
    }
}