IT俱乐部 Python python进程池Pool中apply方法与apply_async方法的区别

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

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

阻塞

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

非阻塞

非阻塞的逻辑和阻塞相反,就是前面人不走,你就在旁边待着,让后面人先走,

apply就是属于上面的阻塞模式,apply_async属于非阻塞模式

1.apply实例

import multiprocessing
def fun(name):
    print(name)


if __name__=="__main__":
    pool = multiprocessing.Pool(3)
    for i in range(1,6):
        st = "start {}".format(i)
        pool.apply(func=fun,args=(st,))

    print("this is flag!")
    pool.close()
    pool.join()

通过下面的执行结果的截图可以发现,print("this is flag!")在线程池里的任务执行完毕后才执行

2.apply_async实例

import multiprocessing
def fun(name):
    print(name)


if __name__=="__main__":
    pool = multiprocessing.Pool(3)
    for i in range(1,6):
        st = "start {}".format(i)
        pool.apply_async(func=fun,args=(st,))

    print("this is flag!")
    pool.close()
    pool.join()

apply_async中的print("this is flag!")代码是在进程池之前执行

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持IT俱乐部。

本文收集自网络,不代表IT俱乐部立场,转载请注明出处。https://www.2it.club/code/python/9660.html
上一篇
下一篇
联系我们

联系我们

在线咨询: QQ交谈

邮箱: 1120393934@qq.com

工作时间:周一至周五,9:00-17:30,节假日休息

关注微信
微信扫一扫关注我们

微信扫一扫关注我们

返回顶部