def task():
print("Executing our Task on Process {}".format(os.getpid()))
def main():
executor = ProcessPoolExecutor(max_workers=3)
task1 = executor.submit(task)
task2 = executor.submit(task)
if __name__ == '__main__':
main()
所以我从这个网站上看到了这个程序:https://tutorialedge.net/python/concurrency/python-processpoolexecutor-tutorial/
而且我只是想知道您是否可以在任务下具有多个功能。就像进程池只应该执行一项任务一样吗?因为我有一个程序,可以执行每个任务,并且想知道如何将其转换为进程池执行程序。
任何帮助将不胜感激。谢谢
A ProcessPoolExecutor
是ProcessPoolExecutor
的子类。 Executor
方法如下所示:
Executor.submit()
根据 submit(fn, *args, **kwargs)
:
调度可调用对象fn,将其作为fn(* args ** kwargs)执行,并返回表示可调用对象的执行的Future对象。
因此它应该能够运行any可调用的-执行程序与其可执行的任务类型之间没有关系。
这里是您提供的代码的简单扩展,可以用来试用:
documentation