# __author: "ZXYang"
# date: 2020/5/16
import queue
qu = queue.Queue(3)
qu.put(‘a1‘)
qu.put(‘a2‘)
qu.put(‘a3‘)
# qu.put(‘a4‘) # 添加数据(若数据已满,会一直等待)
# qu.put(‘a5‘, block=False) # (block=False)[添加不等待]
# qu.put(‘a6‘, timeout=3) # 超时时间,抛异常
# qu.put_nowait(7) # [添加不等待]
# print(qu.get())
# print(qu.get())
# print(qu.get())
# print(qu.get(0))
for i in range(3):
print(qu.get()) # 获取数据,无数据一直等待
# print(qu.get_nowait()) # [添加不等待]
# print(qu.get(timeout=2)) # 超时时间,抛异常
# print(qu.get(block=False)) # (block=False)[添加不等待]
qu.task_done() # 通知队列执行完毕------------------与join组合使用
# print(qu.full()) # 队列是否已满:True / False
# print(qu.empty()) # 队列是否为空:True / False
# print(qu.qsize()) # 获取队列数据量
# qu.task_done()
qu.join() # 等待队列中的消息使用完毕
print(‘--join----join--‘)
原文:https://www.cnblogs.com/zxy01/p/14164760.html