python 生产者消费者模型

1 import queue
2 import threading
3
4 q = queue.Queue(10)
5 def product(i):
6     print('put:'+ str(i))
7     q.put(i)
8
9 def customer(i):
10     msg = q.get()
11     print(msg)
12
13 for i in range(12):
14     t = threading.Thread(target=product,args=(i,))
15     t.start()
16
17 for i in range(10):
18     t = threading.Thread(target=customer,args=(i,))
19     t.start()