场景是使用 tornado 写了一个服务,涉及到一些耗 cpu 的计算,使用了concurrent.futures.ProcessPoolExecutor。
那么最佳实践应该是每次请求时初始化一个进程池,还是保持一个全局的进程池?
class MyHandler(BaseHandler):
@coroutine
def post(self, *args, **kwargs):
...
with ProcessPoolExecutor() as process_pool:
fs = [process_pool.submit(job) for job in jobs]
...
还是这样?
class MyHandler(BaseHandler):
process_pool = ProcessPoolExecutor()
@coroutine
def post(self, *args, **kwargs):
...
fs = [self.process_pool.submit(job) for job in jobs]
...