Python实现生产者消费者模型

题目

Python实现生产者消费者模型

项目地址

生产者-消费者模型进阶

思路

  • 将生产者、消费者和消息队列设为三条进程执行,之间通过socket通信

  • 消息队列拥有4条工作线程的线程池,另外再开两条线程与消费者和生产者进行通信

  • 生产者生产出数据后将数据发送给消息队列,消息队列将数据放进数据队列后,向生产者发送操作成功的响应

  • 当生产者将全部数据发给消息队列后,生产者和消息队列的通信中断

  • 消费者向消息队列发送请求,消息队列将数据发给消费者

  • 消费者对数据进行运算

  • 当数据队列为空后,消费者和消息队列的通行中断