多进程实现生产者消费者
生活随笔
收集整理的這篇文章主要介紹了
多进程实现生产者消费者
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
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()
?
轉載于:https://www.cnblogs.com/gkl123/p/9742055.html
總結
以上是生活随笔為你收集整理的多进程实现生产者消费者的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： winform app.cpnfig 文
- 下一篇： jvm内置锁synchronized不能