生产者就是只做一件事就是生产一个资源放入管道,供消费者消费,消费者也知做一件事,就是从管道中取出一个资源进行消费
代码片段:
import queue
import time
#创建一个队列
import threading
q = queue.Queue()
def producer(args):
while True:
time.sleep(2)
q.put(args)
print("线程%s生产了一个资源"%args)
def consumer(args):
while True:
time.sleep(2)
v1 = q.get()
print("线程%s取走了一个资源"%args)
#创建三个线程作为生产者生产资源
for i in range(1,4):
t = threading.Thread(target=producer,args=(i,))
t.start()
#创建两个线程作为消费者消费资源
for i in range(1,3):
t = threading.Thread(target=consumer,args=(i,))
t.start()



