如何在Python中的多个进程之间共享结果队列？

如何在多个进程之间共享结果队列

使用 multiprocessing 模块的 apply_async 处理异步工作进程时() 函数中，重要的是要考虑如何安全地共享队列。错误“RuntimeError：队列对象只能通过继承在进程之间共享”突出显示需要以防止 pickling/unpickling 问题的方式传递队列。

要解决此问题，我们可以利用 multiprocessing.Manager () 类，它提供了一种管理对象并使它们可供不同工作人员访问的方法。

<code class="python">import multiprocessing

def worker(name, que):
    que.put("%d is done" % name)

if __name__ == '__main__':
    pool = multiprocessing.Pool(processes=3)
    m = multiprocessing.Manager()
    q = m.Queue()
    workers = pool.apply_async(worker, (33, q))</code>

在此示例中，我们创建一个 Manager 对象 (m) 并使用它来管理队列（q）。通过这样做，我们创建了一个共享内存段，即使在异步场景中，该共享内存段也允许多个进程安全地访问队列。

以上是如何在Python中的多个进程之间共享结果队列？的详细内容。更多信息请关注PHP中文网其他相关文章！