实例讲解Python进程池apply_async和apply的区别

 时间:2024-11-05 14:03:14

1、启动Ubuntu虚拟机,在桌面空白处右键 -- 打开终端。

实例讲解Python进程池apply_async和apply的区别

2、打开终端后,在终端输入命令:gedit apply.py创建一个apply.py文件,并在gedit中打开

实例讲解Python进程池apply_async和apply的区别

3、在apply.py文件中写代码如下:from multiprocessing import Poolimport os,timedef work(msg): print ('%s进程开始工作:%s' %(os.getpid(),msg))po = Pooll(3)for i in range(5): po.apply_async(work,(i,))这是使用apply_async执行调用函数的方式。

实例讲解Python进程池apply_async和apply的区别

4、继续编写代码,代码如下:from multiprocessing import Poolimport os,timedef work(msg): time.sleep(0.5) print ('%s进程开始工作:%s' %(os.getpid(),msg)) print ('%s进程结束工作:%s' %(os.getpid(),msg))po = Pool(3)for i in range(5): po.apply_async(work,(i,))po.close()po.join()注意没有最后这两行的话,程序运行会直接结束,主进程不会等待子进程的结束。

实例讲解Python进程池apply_async和apply的区别

5、保存代码,在终端运行代码,使用命令:python3 apply.py

实例讲解Python进程池apply_async和apply的区别

6、回车后,代码运行效果如下图所示,由于在子进程中设置了sleep5秒,所以进程池创建的3子进程,执行先后顺序不一,这是apply_async异步执行的特点。

实例讲解Python进程池apply_async和apply的区别

7、修改代码,使用apply函数,代码如下:from multiprocessing import Poolimport os,timedef work(msg): time.sleep(0.5) print ('%s进程开始工作:%s' %(os.getpid(),msg)) print ('%s进程结束工作:%s' %(os.getpid(),msg))po = Pool(3)for i in range(5): po.apply(work,(i,))po.close()po.join()

实例讲解Python进程池apply_async和apply的区别

8、保存代码,在终端运行代码python3 apply.py代码执行效果如下图,子进程执行的顺序是for循环的顺序,这是因为apply函数每次会等待子进程结束,才执行主进程的for循环操作。

实例讲解Python进程池apply_async和apply的区别
  • Python 进程间的数据共享和进程池
  • Python进程池如何使用
  • Python实例讲解XPath语法
  • 实例讲解Python中的yield协程
  • python模块和包的区别
  • 热门搜索
    什么隔离霜好用 教师节送什么礼物最好 最近有什么好看的电视剧 暴殄天物什么意思 子网掩码是什么 honey是什么意思中文 水光针是什么 非负整数是什么 什么是辛辣食物 端午节又叫什么节