多线程实现生产者消费者

2021-05-19 21:30

阅读:405

标签:sum   style   ==   threading   super   code   data   get   rod   

 1 import threading
 2 import random
 3 import queue
 4 import time
 5 
 6 
 7 class Producer(threading.Thread):
 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(threading.Thread):
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 = queue.Queue()
33     pro = Producer(q)
34     con = Consumer(q)
35     pro.start()
36     con.start()
37     pro.join()
38     con.join()

 

多线程实现生产者消费者

标签:sum   style   ==   threading   super   code   data   get   rod   

原文地址:https://www.cnblogs.com/gkl123/p/9742066.html


评论


亲,登录后才可以留言!