如何使用 multiprocessing.Manager 在多個進程之間共用結果佇列？

使用multiprocessing.Manager 在多個進程之間共享結果隊列

在多處理中，父子進程之間共享隊列對於通訊和結果檢索至關重要。然而，使用 apply_async 啟動非同步工作進程在共享佇列方面提出了挑戰。

為了克服「佇列物件只能透過繼承在進程之間共享」錯誤，我們可以利用 multiprocessing.Manager。此管理器類別可以建立和管理共用資源，包括佇列。

透過將佇列建立包含在 multiprocessing.Manager() 上下文中，我們可以使其可供所有工作人員存取。這是修改程式碼的方法：

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

現在，每個工作人員都可以與共用 q 物件互動並將結果回報給基本流程。這種方法允許高效可靠的結果通信，同時保持 apply_async 的非同步性質。

以上是如何使用 multiprocessing.Manager 在多個進程之間共用結果佇列？的詳細內容。更多資訊請關注PHP中文網其他相關文章！