多进程实现生产者消费者

Posted gkl123

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了多进程实现生产者消费者相关的知识,希望对你有一定的参考价值。

 1 # 多进程实现生产者消费者模型
 2 import multiprocessing
 3 import random
 4 import time
 5 
 6 
 7 class Producer(multiprocessing.Process):
 8     def __init__(self, que):
 9         super().__init__()
10         self.que = que
11 
12     def run(self):
13         while True:
14             data = random.randint(0, 100)
15             print("生产者生产了:", data)
16             self.que.put(data)
17             time.sleep(1)
18 
19 
20 class Consumer(multiprocessing.Process):
21     def __init__(self, que):
22         super().__init__()
23         self.que = que
24 
25     def run(self):
26         while True:
27             item = self.que.get()
28             print("消费者消费了:", item)
29 
30 
31 if __name__ == __main__:
32     q = multiprocessing.Manager().Queue()
33     pro = Producer(q)
34     pro.start()
35     con = Consumer(q)
36     con.start()
37     pro.join()

 

以上是关于多进程实现生产者消费者的主要内容,如果未能解决你的问题,请参考以下文章

Java多线程(实现多线程线程同步生产者消费者)

关于python多进程使用(Queue、生产者和消费者)

多进程生产者消费者框架设计

多进程生产者消费者框架设计

多进程生产者消费者框架设计

Java实现多线程生产者消费模型及优化方案