python进程池Pool中apply方法与apply_async方法的区别

一棵小小草

在掌握apply方法与apply_async的区别之前，需要了解阻塞和非阻塞的区别

阻塞

阻塞好比过独木桥，前面人不走，后面人就无法先前走，只有前面人过了独木桥，后面人才能继续向前走

非阻塞

非阻塞的逻辑和阻塞相反，就是前面人不走，你就在旁边待着，让后面人先走，
apply就是属于上面的阻塞模式，apply_async属于非阻塞模式

1.apply实例

1. import multiprocessing
   
2. def fun(name):
   
3.     print(name)
   
4. 
   
5. 
   
6. if __name__=="__main__":
   
7.     pool = multiprocessing.Pool(3)
   
8.     for i in range(1,6):
   
9.         st = "start {}".format(i)
   
10.         pool.apply(func=fun,args=(st,))
    
11. 
    
12.     print("this is flag!")
    
13.     pool.close()
    
14.     pool.join()

复制代码

通过下面的执行结果的截图可以发现，

1. print("this is flag!")

复制代码

在线程池里的任务执行完毕后才执行

2.apply_async实例

1. import multiprocessing
   
2. def fun(name):
   
3.     print(name)
   
4. 
   
5. 
   
6. if __name__=="__main__":
   
7.     pool = multiprocessing.Pool(3)
   
8.     for i in range(1,6):
   
9.         st = "start {}".format(i)
   
10.         pool.apply_async(func=fun,args=(st,))
    
11. 
    
12.     print("this is flag!")
    
13.     pool.close()
    
14.     pool.join()

复制代码

apply_async中的

1. print("this is flag!")

复制代码

代码是在进程池之前执行

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

来源:https://www.jb51.net/python/316256u1b.htm
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！