# 新版本的进程池 ProcessPoolExecutor
# 实例化进程池 ProcessPoolExcutor(cpu_count)
# 异步提交任务 submit / map
# 阻塞直到任务完成 shutdown
# 获取子进程的返回值 result
# 使用回调函数 add_done_callback
基本用法和线程池语法一样
from concurrent.futures import ThreadPoolExecutor, ProcessPoolExecutor
import time
def func(i):print("Process", i)time.sleep(1)print("Process is end ")
if __name__ &＃61;&＃61; "__main__":# ProcessPoolExecutor <&＃61;&＃61;> Poolp &＃61; ProcessPoolExecutor(5)# submit <&＃61;&＃61;> apply_asyncp.submit(func, 1)# shutdown <&＃61;&＃61;> close &＃43; join
p.shutdown()print("主线程")
执行结果:
Process 1
Process is end
主线程
京公网安备 11010802041100号