题目
在这里插入图片描述项目地址
思路
-
将生产者、消费者和消息队列设为三条进程执行,之间通过socket通信
-
消息队列拥有4条工作线程的线程池,另外再开两条线程与消费者和生产者进行通信
-
生产者生产出数据后将数据发送给消息队列,消息队列将数据放进数据队列后,向生产者发送操作成功的响应
-
当生产者将全部数据发给消息队列后,生产者和消息队列的通信中断
-
消费者向消息队列发送请求,消息队列将数据发给消费者
-
消费者对数据进行运算
-
当数据队列为空后,消费者和消息队列的通行中断
将生产者、消费者和消息队列设为三条进程执行,之间通过socket通信
消息队列拥有4条工作线程的线程池,另外再开两条线程与消费者和生产者进行通信
生产者生产出数据后将数据发送给消息队列,消息队列将数据放进数据队列后,向生产者发送操作成功的响应
当生产者将全部数据发给消息队列后,生产者和消息队列的通信中断
消费者向消息队列发送请求,消息队列将数据发给消费者
消费者对数据进行运算
当数据队列为空后,消费者和消息队列的通行中断
本文标题:Python实现生产者消费者模型
本文链接:https://www.haomeiwen.com/subject/wkogkqtx.html
网友评论