Go语言GO语言系列Go

GO语言初级学习之代码案例08(生产者消费者模型)

2018-08-16  本文已影响16人  大爬虫Shalom

GO语言初级学习之代码案例08-生产者消费者模型

@(go语言 黑马)[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()
    }
}
上一篇 下一篇

猜你喜欢

热点阅读