在我的 Python 3 应用程序中,我必须处理许多不应阻塞主线程的小型(同时)I/O 任务,因此我想利用线程池:
from concurrent.futures import ThreadPoolExecutor
class MyApp:
def __init__(self):
self.app_thread_pool = ThreadPoolExecutor()
def submit_task(self, task):
self.app_thread_pool.submit(MyApp.task_runner, task)
@staticmethod
def task_runner(task):
# Do some stuff with the task, save to disk, etc.
这工作正常,作业正在线程池的线程中提交和启动,任务执行它们应该执行的操作。现在,阅读该concurrent.futures模块的文档,似乎该模块/线程池将与Future对象一起使用,以便处理提交任务的结果。然而,就我而言,我对这些结果不感兴趣,我想解雇并忘记我的任务,他们能够处理自己。
所以我的问题是:我是否必须使用 futures,或者我可以简单地执行submit()一个任务,如上所示,并忽略Future从作业提交返回的任何对象?我问的是内存和资源管理方面。请注意,我也不想使用该with语句来使用线程池,如文档中所述,因为我在应用程序的整个生命周期中都需要这个线程池,并且启动线程池的主线程还有许多其他事情要做...
白衣染霜花
相关分类