from queue import Queue import random import threading import time
Producer thread
class Producer(threading.Thread): def init(self, t_name, queue): threading.Thread.init(self, name=t_name) self.data = queue
代码语言：javascript复制def run(self):
for i in range(5):
print("%s: %s is producing %d to the queue!" % (time.ctime(), self.getName(), i))
self.data.put(i)
time.sleep(random.randrange(10) / 5)
print("%s: %s finished!" % (time.ctime(), self.getName()))Consumer thread
class Consumer(threading.Thread): def init(self, t_name, queue): threading.Thread.init(self, name=t_name) self.data = queue
代码语言：javascript复制def run(self):
for i in range(5):
val = self.data.get()
print("%s: %s is consuming. %d in the queue is consumed!" % (time.ctime(), self.getName(), val))
time.sleep(random.randrange(10))
print("%s: %s finished!" % (time.ctime(), self.getName()))Main thread
def main(): queue = Queue() producer = Producer('Pro.', queue) consumer = Consumer('Con.', queue) producer.start() consumer.start() producer.join() consumer.join() print('All threads terminate!')
if name == 'main': main()
import queue
q = queue.Queue(3) # 调用构造函数，初始化一个大小为3的队列 print(q.empty()) # 判断队列是否为空，也就是队列中是否有数据
入队，在队列尾增加数据， block参数，可以是True和False 意思是如果队列已经满了则阻塞在这里，
timeout 参数 是指超时时间，如果被阻塞了那最多阻塞的时间，如果时间超过了则报错。
q.put(13, block=True, timeout=5) print(q.full()) # 判断队列是否满了，这里我们队列初始化的大小为3 print(q.qsize()) # 获取队列当前数据的个数
block参数的功能是 如果这个队列为空则阻塞，
timeout和上面一样，如果阻塞超过了这个时间就报错，如果想一只等待这就传递None
print(q.get(block=True, timeout=None))
queue模块还提供了两个二次封装了的函数，
q.put_nowait(23) # 相当于q.put(23, block=False) q.get_nowait() # 相当于q.get(block=False)
