码迷,mamicode.com
首页 > 编程语言 > 详细

Go语言协程并发---生产者消费者实例

时间:2020-04-24 19:58:50      阅读:94      评论:0      收藏:0      [点我收藏+]

标签:watch   int   通知   false   func   now()   ==   结束   bag   

package main

import (
	"fmt"
	"strconv"
	"time"
)

/*
改进生产者消费者模型
·生产者每秒生产一件商品,并通知物流公司取货
·物流公司将商品运输到商店
·消费者阻塞等待从商店消费
·消费10轮就主协程结束
·尝试在整分钟时通知生产者罢工,生产者罢工时主协程结束
·计时协程,不断地查看有没有到整分钟
·如果到整分钟,将【全局罢工变量】置为true
·生产者每完成一轮生产就查看【全局罢工变量】,如果为true就向【chGoDie】写入值
*/

type Product struct {
	Name string
}

var chGoDie = make(chan interface{})
func main() {
	chStorage := make(chan Product, 5)
	chShop:= make(chan Product, 5)


	go Producer(chStorage)
	go Logistics(chStorage, chShop)
	go Consumer(chShop)
	go Watcher()

	//阻塞等待狗带命令
	<-chGoDie
	fmt.Println("main:啊!我死了")
}

/*计时协程*/
var Bagong = false
func Watcher()  {
	for true {
		second := time.Now().Second()
		fmt.Println("当前秒数", second)
		if second ==0{
			fmt.Println("罢工开始!!!!!")
			Bagong = true
			return
		}

		time.Sleep(time.Second)
	}
}

/*物流公司*/
func Logistics(chStorage chan Product, chShop chan Product)  {
	for true {
		product:=<-chStorage
		chShop <- product
		fmt.Println("转运了",product)
	}

}

/*生产者*/
func Producer(chStorage chan Product)  {
	for {
		product := Product{"商品" + strconv.Itoa(time.Now().Second())}
		chStorage<-product
		fmt.Println("生产了",product)
		if Bagong {
			fmt.Println("收到!Go Die主协程")
			chGoDie <- "Go Die!"
		}
		time.Sleep(time.Second)

	}
}

/*消费者*/
func Consumer(chShop chan Product)  {
	for {
		product :=<- chShop
		fmt.Println("消费了",product)
	}
}

  

Go语言协程并发---生产者消费者实例

标签:watch   int   通知   false   func   now()   ==   结束   bag   

原文地址:https://www.cnblogs.com/yunweiqiang/p/12769670.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!