我正在尝试使用Python的pathos将计算指定到单独的进程中,以便使用多核处理器进行加速。我的代码是这样组织的: def foo(self,name): setattr(self,name,something) for name in list:由于我在使用multiprocessing.Pool时遇到了一些问题,我决定尝试一下pathos我试过了,正如前面的主题所建议的那样:
所以我的问题是,在我的代码中,实际上是由两个python模块组成的,一个是主模块,另一个是子模块。在sub中有一个函数,我需要它来停止工作,并将控制返回到主模块的下一行。这是怎么做到的。() print('inside error')
return #in place of this所以我想要的是,当我的代码进入error函数时,它将打印语句,模块2结束执行,控
我正在写一些使用多处理的python代码& pathos。我已经写了一个小的测试程序来习惯使用多进程,它在我的本地机器上运行得很好,但它拒绝在不同的集群上运行。我收到以下错误: File "./multi.py", line 116, in <module>
pool = pathos_multiprocessing.Pool(processes=pool_size,maxtasksperch