使用多處理管理共享佇列
在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中文網其他相關文章!