消费者生产者模式

# 同步的、线程安全的队列 import threading from queue import Queue class Producer(threading.Thread): def run(self): global que while True: if que.qsize() < 10: que.put('这是生产者生产的数据') class Consumer(threading.Thread): def run(self): global que while True: if que.qsize()>0: print(self.name,'消费数据',que.get()) # for q in range(que.qsize()+1): # que.get() # print(self.name, '消费数据', que.get()) # if que.empty(): # break if __name__ == '__main__': # 创建队列 que = Queue() # 生产数据 producer = Producer() producer.start() # 消费数据 consumer = Consumer() consumer.start()