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

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

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

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

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

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