在Python中,queue
模块提供了实现FIFO(先进先出)队列的类Queue
和deque
,以及实现优先级队列的类PriorityQueue
。下面是queue
模块中常用的几种函数的使用方法:
import queue
q = queue.Queue() # 创建一个FIFO队列
q = queue.LifoQueue() # 创建一个LIFO队列
q = queue.PriorityQueue() # 创建一个优先级队列
q.put(item) # 将元素item放入队列中
item = q.get() # 从队列中获取元素,并将其从队列中移除
empty = q.empty() # 返回True,如果队列为空;否则返回False
size = q.qsize() # 返回队列中元素的数量
import queue
import threading
def worker(q):
while not q.empty(): # 如果队列不为空
item = q.get() # 从队列中获取元素
# 进行相应的处理操作
print(item)
q = queue.Queue()
# 向队列中添加元素
for i in range(10):
q.put(i)
# 创建多个线程,每个线程从队列中获取元素并进行处理
threads = []
for _ in range(5):
t = threading.Thread(target=worker, args=(q,))
t.start()
threads.append(t)
# 等待所有线程执行完毕
for t in threads:
t.join()
上述代码创建了一个队列,并向队列中添加了10个元素。然后创建了5个线程,每个线程从队列中获取元素并进行处理。最后,等待所有线程执行完毕。注意在多线程环境中使用队列需要考虑线程安全性,可以使用queue.Queue
类本身提供的线程安全机制来保证安全访问。