我正在使用多处理模块。这个模块是在队列上工作的,队列是它的随机挑选过程,并从队列中分配入口。
我想决定哪个进程将在队列的哪个条目上工作
我将向队列传递2个参数
multiprocessing.Process
child_procs = {'name1' : Process(target=myprocfunc, name='name1'), ...}
至于父进程和子进程之间的IPC,只需维护一个单独的 multiprocessing.Queue 对于每个子进程。您需要一个任务分配对象/函数来分配工作。此函数可能负责从主/中心队列中弹出任务,然后将其分配给正确的子进程队列(基于我从您的问题中了解到的体系结构)。
multiprocessing.Queue