import os
from multiprocessing import Pool
from time import sleep
def func1(name):
print(f"当前的进程ID:{os.getpid()},{name}")
sleep(3)
if __name__ =="__main__":
pool=Pool(5)
pool.apply_async(func=func1,args=("jhy1",))
pool.apply_async(func=func1,args=("jhy2",))
pool.apply_async(func=func1,args=("jhy3",))
pool.apply_async(func=func1,args=("jhy4",))
pool.apply_async(func=func1,args=("jhy5",))
pool.apply_async(func=func1,args=("jhy6",))
pool.apply_async(func=func1,args=("jhy7",))
pool.apply_async(func=func1,args=("jhy8",))
pool.close()
pool.join()老师 关于这个进程池就是 池子里一共有5个进程 然后来了8个任务 每个任务都是去调用func1这个函数 先是5个去执行 然后是剩下的3个去执行 这些进程之间是异步执行 同时在进行 不用回收 不用开辟空间 这样节省效率 这样理解对吗
对着笔记敲的时候一直报错,回来看了视屏才发现.
这个图标引不进来
京公网安备 11011402011233号