生产者就是只做一件事就是生产一个资源放入管道,供消费者消费,消费者也知做一件事,就是从管道中取出一个资源进行消费
代码片段:
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()
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)