如何在Python中实现多进程队列的LIFO（后进先出）功能？

Question

我理解队列与栈的不同之处。但如果我启动多个进程，并在它们之间发送消息，将它们放入中，我如何首先访问最新放入队列的元素？

- shijuza

Answer 1

你可以使用多进程管理器来包装一个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()

- Dunes

Answer 2

multiprocessing.Queue不是一种数据类型，而是两个进程之间通信的一种方式。它不能与Stack相比较。

这就是为什么没有API可以弹出队列中的最后一个项目。

我认为你想要的是使某些消息比其他消息具有更高的优先级。当它们被发送到监听进程时，您希望尽快将它们出队，绕过队列中现有的消息。

您实际上可以通过创建两个multiprocessing.Queue来实现此效果：一个用于正常数据有效载荷，另一个用于优先消息。然后，您无需担心获取最后一个项目。只需将两种不同类型的消息分别隔离到两个队列中即可。

- Anthony Kong