多进程实现生产者消费者
生活随笔
收集整理的這篇文章主要介紹了
多进程实现生产者消费者
小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
1 # 多進(jìn)程實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模型
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("生產(chǎn)者生產(chǎn)了：", 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("消費(fèi)者消費(fèi)了：", 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()
?
轉(zhuǎn)載于:https://www.cnblogs.com/gkl123/p/9742055.html
總結(jié)
以上是生活随笔為你收集整理的多进程实现生产者消费者的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： winform app.cpnfig 文
- 下一篇： jvm内置锁synchronized不能