我正在尝试在其他主机上实现Pyro4。
在工作节点上,我以这种方式实现了多处理:
--enable-optimizations
但是,这种多重处理似乎不起作用。
这里的概念是,在每个主机上,内核将被最大化使用。
对此我还是陌生的,我不知道解决方法。
我正在尝试在其他主机上实现Pyro4。
在工作节点上,我以这种方式实现了多处理:
--enable-optimizations
但是,这种多重处理似乎不起作用。
这里的概念是,在每个主机上,内核将被最大化使用。
对此我还是陌生的,我不知道解决方法。
很明显,Pyro4不支持multiprocessing.Pool。
要解决此问题,我以ff方式实现了多处理:
try:
processes = [Process(target=self.__function_name,args=(result,)) for result in enumerate(self.p.results())]
for p in processes:
p.start()
for p in processes:
p.join()
except Exception as e:
print(e)