#1.创建池子
#2.submit 提交任务
#3.shutdown 可以用于等待所有任务完成后销毁池
from concurrent.futures import ThreadPoolExecutor,ProcessPoolExecutor import time,os # 创建进程池,指定最大进程数为3,此时不会创建进程,不指定数量时,默认为CPU核数 pool = ProcessPoolExecutor(3) def task(): time.sleep(1) print(os.getpid(),"working..") if __name__ == '__main__': for i in range(10): # 开启10个任务 pool.submit(task) # 提交任务时立即创建进程 # pool.shutdown() # 关闭池子( 等待池子中所有的任务执行完毕之后 才会往下运行代码,相当于一阻塞) print(1)