我理解队列与栈的不同之处。但如果我启动多个进程,并在它们之间发送消息,将它们放入中,我如何首先访问最新放入队列的元素?
queue.LifoQueue
以实现你想要的功能。from multiprocessing import Process
from multiprocessing.managers import BaseManager
from time import sleep
from queue import LifoQueue
def run(lifo):
"""Wait for three messages and print them out"""
num_msgs = 0
while num_msgs < 3:
# get next message or wait until one is available
s = lifo.get()
print(s)
num_msgs += 1
# create manager that knows how to create and manage LifoQueues
class MyManager(BaseManager):
pass
MyManager.register('LifoQueue', LifoQueue)
if __name__ == "__main__":
manager = MyManager()
manager.start()
lifo = manager.LifoQueue()
lifo.put("first")
lifo.put("second")
# expected order is "second", "first", "third"
p = Process(target=run, args=[lifo])
p.start()
# wait for lifoqueue to be emptied
sleep(0.25)
lifo.put("third")
p.join()
multiprocessing.Queue
不是一种数据类型,而是两个进程之间通信的一种方式。它不能与Stack
相比较。
这就是为什么没有API可以弹出队列中的最后一个项目。
我认为你想要的是使某些消息比其他消息具有更高的优先级。当它们被发送到监听进程时,您希望尽快将它们出队,绕过队列中现有的消息。
您实际上可以通过创建两个multiprocessing.Queue
来实现此效果:一个用于正常数据有效载荷,另一个用于优先消息。然后,您无需担心获取最后一个项目
。只需将两种不同类型的消息分别隔离到两个队列中即可。