python concurrent.futures模块如何使用

python concurrent.futures模块如何使用

这篇文章主要介绍了python concurrent.futures模块如何使用的相关知识，内容详细易懂，操作简单快捷，具有一定借鉴价值，相信大家阅读完这篇python concurrent.futures模块如何使用文章都会有所收获，下面我们一起来看看吧。

概述

concurrent.futures 是 3.2 中引入的新模块，它为异步执行可调用对象提供了高层接口。
可以使用 ThreadPoolExecutor 来进行多线程编程，ProcessPoolExecutor 进行多进程编程，两者实现了同样的接口，这些接口由抽象类 Executor 定义。
这个模块提供了两大类型，一个是执行器类 Executor，另一个是 Future 类。
执行器用来管理工作池，future 用来管理工作计算出来的结果，通常不用直接操作 future 对象，因为有丰富的 API。

说明

Python3.2开始，标准库为我们提供了concurrent.futures模块，它提供了ThreadPoolExecutor和ProcessPoolExecutor两个类，实现了对threading和multiprocessing的进一步抽象，对编写线程池/进程池提供了直接的支持.

#!/usr/bin/envpython#-*-coding:utf-8-*-##-------------------------------------------------------------------------------#Name:demo3#Author:yunhgu#Date:2021/7/815:17#Description:#-------------------------------------------------------------------------------importosimporttimeimportthreadingfromconcurrent.futuresimportProcessPoolExecutor,ThreadPoolExecutor,as_completeddefwork(x):time.sleep(1)temp=f"父进程{os.getppid()}:子进程{os.getpid()}:线程{threading.get_ident()}:{x}"returntempdefsub_thread():temp_list=[]withThreadPoolExecutor(max_workers=3)ast:task_list=[t.submit(work,i)foriinrange(5)]fortaskinas_completed(task_list):iftask.done():temp_list.append(task.result())returntemp_listdefmain():print(f"主进程:{os.getpid()}")path_list=[]withProcessPoolExecutor(max_workers=3)asp:task_list=[p.submit(sub_thread)foriinrange(5)]fortaskinas_completed(task_list):iftask.done():path_list.append(task.result())forpathinpath_list:print(path)if__name__=="__main__":main()

关于“python concurrent.futures模块如何使用”这篇文章的内容就介绍到这里，感谢各位的阅读！相信大家对“python concurrent.futures模块如何使用”知识都有一定的了解，大家如果还想学习更多知识，欢迎关注恰卡编程网行业资讯频道。