1
我正在使用多處理模塊。此模塊適用於Queue,它是隨機挑選過程並從Queue分配entery。如何通過名稱或python中的標記調用進程
我要決定哪些進程將要處理哪個隊列
這是我要求的條目,
我將通過2個參數排隊
- 發起進程名稱
- 行動/方法(什麼過程要做)
它應該僅將隊列條目傳遞給給定的進程。
我正在使用多處理模塊。此模塊適用於Queue,它是隨機挑選過程並從Queue分配entery。如何通過名稱或python中的標記調用進程
我要決定哪些進程將要處理哪個隊列
這是我要求的條目,
我將通過2個參數排隊
它應該僅將隊列條目傳遞給給定的進程。
multiprocessing.Process
對象在初始化時採用可選的名稱參數。您可以使用該名稱作爲在字典中鍵:
child_procs = {'name1' : Process(target=myprocfunc, name='name1'), ...}
至於父進程和孩子之間的IPC,你應該罰款只維持每個子進程單獨multiprocessing.Queue
。您需要一個任務分配對象/功能來分配工作。這個函數可能會負責將任務從主/中央隊列中彈出,然後將其分配給正確的子進程隊列(基於我從你的問題中閃爍的架構)。