如何解決多處理中的「隊列物件只能透過繼承在進程之間共享」錯誤？

使用多處理管理共享佇列

在Python的多處理模組中，在使用multiprocessing.apply_async()時，在進程之間創建共享隊列需要仔細考慮啟動非同步工作進程。 「佇列物件只能透過繼承在進程之間共用。」嘗試將佇列直接傳遞給工作人員時會發生錯誤。

要解決此問題，請使用 multiprocessing.Manager 來管理佇列並使其可供工作進程存取。 multiprocessing.Manager 提供了建立管理器物件的方法，這些物件控制和序列化共享記憶體段中的各種類型的資料。

以下程式碼片段示範如何使用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>

在此範例中，multiprocessing.Manager() 建立一個管理器物件(m)，用於管理共享資料並提供可傳遞給工作進程的代理程式物件。透過呼叫 m.Queue()，我們建立了一個由管理器管理的佇列，所有工作進程都可以存取該佇列。然後，管理器序列化代理物件並將其傳遞給工作器，使其能夠與共用佇列安全地通訊。

以上是如何解決多處理中的「隊列物件只能透過繼承在進程之間共享」錯誤？的詳細內容。更多資訊請關注PHP中文網其他相關文章！