Python中的queue模块提供了多种队列类型,可以用于实现线程间的安全通信。常见的队列类型有以下几种:
put(item, block=True, timeout=None):将item放入队列中,block为True时表示如果队列已满则等待,timeout为等待时间。
get(block=True, timeout=None):从队列中取出一个元素,block为True时表示如果队列为空则等待,timeout为等待时间。
qsize():返回队列中元素的数量。
empty():判断队列是否为空。
full():判断队列是否已满。
LifoQueue:后进先出(LIFO)队列,与栈的行为类似。常用函数与Queue相同。
PriorityQueue:优先级队列,元素按照优先级从小到大排序。常用函数与Queue相同。
SimpleQueue:简单队列,只包含put和get方法,无法设置阻塞和超时等参数。
下面是一个使用Queue队列的示例代码:
from queue import Queue
# 创建一个队列对象
q = Queue()
# 向队列中放入元素
q.put(1)
q.put(2)
q.put(3)
# 从队列中取出元素
print(q.get()) # 输出1
print(q.get()) # 输出2
print(q.get()) # 输出3
# 判断队列是否为空
print(q.empty()) # 输出True
需要注意的是,队列对象中的put和get方法会自动实现线程间的同步,因此可以在多线程环境下安全使用。