# 三种 FIFO  LIFO Priority

# 创建先入先出的队列

# q = queue.Queue()

# q.qsize()  # 返回当前队列包含的消息数量

# q.empty()  # 如果队列为空返回True 反之False

# q.full()  # 如果队列满了，返回True 反之False

# q.get()  # 获取队列，timeout等待时间  get(self, block=True,timeout=None) block表示是否等待 timeout表示等待多久

# q.put(item)  # 写入队列 put(self, item, block=True,timeout=None) block表示是否等待 timeout表示等待多久

# q.get_nowait()  # 相当于q.get(False) 获取不等待

# q.put_nowait()  # 相当于 q.put(item,False) 写入不等待

# q.task_done()  # 在完成一项工作之后，使用这个方法可以向队列发送一个信号，表示该任务执行完毕

# q.join()  # 等待队列中所有任务（数据）执行完毕之后再往下执行，否则一直等待

# 注意点 ：join是判断的依据。不单单指的是队列中没有数据，数据get出去之后，要使用task_done向队列发送一个信号，表示该任务执行完毕

# /数据使用完毕

import queue

q1 = queue.Queue(3)  # 定义3 指定队列长度 表示只能塞3条数据 不写可以无限塞

q1.put(1)  # 等待插入

q1.put(11)

q1.put(33)

# q1.put(33,block=False)  # 不等待插入 满了之后报错

# q1.put_nowait(33)  # 不等待插入 满了之后报错

print(q1.get())

print(q1.get())  # 先入先出获取 1先出 33最后出

print(q1.get())

# print(q1.get(block=False))  # 不等待获取 队列为空报错

# print(q1.get_nowait()) # 不等待获取 队列为空报错

# q1.put(3)

print(q1.qsize())  # 获取队列中的任务数/消息数

print(q1.full())  # 判断队列是否已满

print(q1.empty())  # 判断队列是否为空

q1.task_done()

q1.task_done()

q1.task_done() # 插入一条数据使用完成之后就要发送一条消息

q1.join()  # 收到task_done返回的信号，当都使用完成之后才会继续往下执行  如果任务没有完成那将不会向下执行

print('join之后')

import queue

q = queue.LifoQueue(3)

q.put(1)
q.put(2)
q.put(3)
print(q.get())
print(q.get())
print(q.get())  # 后进先出 其他方法与FIFO相同

import queue

q = queue.PriorityQueue(3)  # 其他方法与 FIFO 相同

q.put((1, '哈哈1'))  # 接受元组为参数 第一个是优先级数字型的 第二个是数据

q.put((88, '哈哈88'))

q.put((3, '哈哈3'))

print(q.get())

print(q.get())

print(q.get())  # 根据前面的优先级出，优先级数字小的先出