Go语言编程:使用条件变量Cond和channel通道实现多个生产者和消费者模型
如题,使用条件变量Cond和channel通道实现多个生产者和消费者模型。Go语言天生带有C语言的基因,很多东西和C与很像,但是用起来 绝对比C语言方便。今天用Go语言来实现下多消费者和生产者模型。如果对C语言的多生产者和消费者模型感兴趣的可以看Linux系统编程:使用mutex互斥锁和条件变量实现多个生成者和消费者模型
代码实现
代码实现用了Cond条件变量和channel通道。
package main
import (
"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 <- num
fmt.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 := <-in
fmt.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
}
运行效果
相关文章
- 2022-09-24:以下go语言代码输出什么?A:1;B:3;C:13;D:7。 package main import ( “fmt“ “io/ioutil
- 2022-08-19:以下go语言代码输出什么?A:equal;B:not equal;C:不确定。 package main import ( “fmt“ “
- 「一周汇总」直播编程视频合集(附代码),一篇入门Go语言
- 《Go语言精进之路:从新手到高手的编程思想、方法和技巧1》7-9章笔记
- 1.Go语言编程学习课后实践
- 2022-10-04:以下go语言代码输出什么?A:{123} main.T{x:123} B:{123} T{x:123} C:boo boo D:boo m
- 2022-10-10:以下go语言代码输出什么?A:[1 2 3 0 1 2];B:死循环;C:[1 2 3 1 2 3];D:
- JetBrains GoLand 2022 for Mac(GO语言集成开发工具环境)
- Linux运维必知必会的Go语言核心知识,找齐了 | 极客时间
- Go语言集成开发环境(IDE)大汇总
- Go从入门到精通(一)go语言初识详解编程语言
- Go语言圣经–Map习题详解编程语言
- 使用Go语言来操作Oracle数据库(go语言oracle)
- Go语言网络爬虫多重读取器的实现
- Go语言将函数作为返回值
- Go语言Socket编程详解
- Go语言和其它编程语言的对比
- 使用 Go 实现 TLS socket server
- 2017 年 Go 语言编程的五大关注点
- 部署Go语言快速连接Oracle实现轻松部署(go连接oracle简单)
- 新技术Go语言解析Oracle数据库日志(go解析oracle日志)
- 程序Go语言调用Oracle数据库驱动程序指南(go oracle驱动)
- GO语言并发编程之互斥锁、读写锁详解