经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » 程序设计 » Python » 查看文章
python Pool常用函数用法总结
来源:jb51  时间:2021/4/19 10:26:46  对本文有异议

1、说明

apply_async(func[,args[,kwds]):使用非堵塞调用func(并行执行,堵塞方式必须等待上一个过程退出才能执行下一个过程),args是传输给func的参数列表,kwds是传输给func的关键词参数列表。

close():关闭Pool,使之不再接受新任务。

terminate():无论任务是否完成,都要立即终止。

join():主进程堵塞,等待子进程退出,必须在close或terminate之后使用。

2、实例

  1. #coding: utf-8
  2. import multiprocessing
  3. import time
  4. def func(msg):
  5. print("msg:", msg)
  6. time.sleep(3)
  7. print("end")
  8. if __name__ == "__main__":
  9. cores = multiprocessing.cpu_count()
  10. pool = multiprocessing.Pool(processes=cores)
  11. print("Adding tasks...")
  12. for i in range(cores):
  13. msg = "hello %d" %(i)
  14. pool.apply_async(func, (msg, )) #维持执行的进程总数为processes,当一个进程执行完毕后会添加新的进程进去
  15. print("Starting tasks...")
  16. pool.close()
  17. pool.join() #调用join之前,先调用close函数,否则会出错。执行完close后不会有新的进程加入到pool,join函数等待所有子进程结束
  18. print("Sub-process(es) done.")

实例扩展:

  1. # -*- coding:utf-8 -*-
  2. from multiprocessing import Pool
  3. import os, time, random
  4. def worker(msg):
  5. t_start = time.time()
  6. print("%s开始执行,进程号为%d" % (msg,os.getpid()))
  7. # random.random()随机生成0~1之间的浮点数
  8. time.sleep(random.random()*2)
  9. t_stop = time.time()
  10. print(msg,"执行完毕,耗时%0.2f" % (t_stop-t_start))
  11. po = Pool(3) # 定义一个进程池,最大进程数3
  12. for i in range(0,10):
  13. # Pool().apply_async(要调用的目标,(传递给目标的参数元祖,))
  14. # 每次循环将会用空闲出来的子进程去调用目标
  15. po.apply_async(worker,(i,))
  16. print("----start----")
  17. po.close() # 关闭进程池,关闭后po不再接收新的请求
  18. po.join() # 等待po中所有子进程执行完成,必须放在close语句之后
  19. print("-----end-----")
  20.  

运行结果

----start----
0开始执行,进程号为21466
1开始执行,进程号为21468
2开始执行,进程号为21467
0 执行完毕,耗时1.01
3开始执行,进程号为21466
2 执行完毕,耗时1.24
4开始执行,进程号为21467
3 执行完毕,耗时0.56
5开始执行,进程号为21466
1 执行完毕,耗时1.68
6开始执行,进程号为21468
4 执行完毕,耗时0.67
7开始执行,进程号为21467
5 执行完毕,耗时0.83
8开始执行,进程号为21466
6 执行完毕,耗时0.75
9开始执行,进程号为21468
7 执行完毕,耗时1.03
8 执行完毕,耗时1.05
9 执行完毕,耗时1.69
-----end-----

到此这篇关于python Pool常用函数用法总结的文章就介绍到这了,更多相关python Pool常用函数有哪些内容请搜索w3xue以前的文章或继续浏览下面的相关文章希望大家以后多多支持w3xue!

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号