蟒蛇继续使用相同的线程持续时间长为长时间运行过程

Question

我有我想保持运行超过6小时模型并联：

pool = multiprocessing.Pool(10) 
for subModel in self.model: 
    pool.apply_async(self.compute, subModel, features) 
pool.close() 
pool.join() 

现在的问题是速度太慢，因为我有调用pool = multiprocessing.Pool（10）和pool.join（），每次构建和解构10个线程，而模型在6个小时内运行多次。

我认为解决方案有10个线程在后台继续运行，这样每当有新数据进入时，它都会马上进入模型，而不用担心创建新线程和解构浪费大量时间的线程。

python有没有办法让你有很长的运行过程，这样你就不需要一遍又一遍地重新开始和停止了？

Answer 1

在向其提交一组任务后，您不需要close()和join()（并销毁）Pool。如果您想确保您的apply_async()已完成，请拨打apply()，下次再使用相同的Pool。或者，如果您在等待任务时可以做其他事情，请保存由apply_async返回的结果对象，并在其上面调用wait()，一旦无法继续完成。