目的:主要是为了提高效率
实例代码:
from queue import Queue #导入队列
from threading import Thread #导入线程
import time
q = Queue(maxsize=10)
生产者
def cooker(name):
count = 1
while True:
q.put('包子%d'%count)
print('%s---生产了---包子%d'%(name,count))
count +=1
time.sleep(2)
消费者
def consumer(name):
while True:
print('%s吃了%s'%(name,q.get()))
time.sleep(1)
主函数
if __name__ == '__main__':
#厨师1
c1 = Thread(target=cooker,args=('刘大厨',))
c1.start() #开始执行
#厨师2
c2 = Thread(target=cooker,args=('李大厨',))
c2.start()
消费者(调用)
guke1 = Thread(target=consumer,args=('小明',))
guke1.start()
guke2 = Thread(target=consumer,args=('铁蛋',))
guke2.start()
运行结果: