博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
进程池的返回值
阅读量:6431 次
发布时间:2019-06-23

本文共 1433 字,大约阅读时间需要 4 分钟。

# import time# from multiprocessing import Pool## def func(i):#     time.sleep(1)#     return i * i### if __name__ == '__main__':#     pool = Pool(4)##     for i in range(10):#         ret = pool.apply(func, args=(i, ))  # 同步任务调用的任务的返回值,一个任务执行完后才能执行下一个任务,直接就是func的返回值#         print(ret)    # 直接打印任务返回值的结果## import time# from multiprocessing import Pool## def func(i):#     time.sleep(1)#     return i * i### if __name__ == '__main__':#     pool = Pool(4)##     for i in range(10):#         ret = pool.apply_async(func, args=(i, ))  # 异步提交任务调用的任务的返回值,返回值得到的是一个任务的返回结果对象#         #print(ret)  # 不调用get方法,直接打印的就是得到任务的返回结果对象#         print(ret.get())    # 调用返回结果的对象的get方法会同步阻塞等待每个任务执行结束后返回的结果## import time# from multiprocessing import Pool## def func(i):#     time.sleep(1)#     return i * i### if __name__ == '__main__':#     pool = Pool(4)#     ret_l = []#     for i in range(10):#         ret = pool.apply_async(func, args=(i, ))  # 异步提交任务调用的任务的返回值,返回值得到的是一个任务的返回结果对象#         ret_l.append(ret)##     for ret in ret_l:#         print(ret.get())    # 阻塞得到进程池中每个任务的返回值,先执行完的任务,则先得到执行完任务的返回值并打印出来import timefrom multiprocessing import Pooldef func(i):    time.sleep(1)    return i * iif __name__ == '__main__':    pool = Pool(4)    ret = pool.map(func, range(10)) # 异步执行10个任务,阻塞等待每个任务执行完毕将返回值返回放到了ret列表中    print(ret)  # [0, 1, 4, 9, 16, 25, 36, 49, 64, 81]  # 一次性打印出上面阻塞等待的10个任务的返回值

 

转载于:https://www.cnblogs.com/whylinux/p/9833152.html

你可能感兴趣的文章
反向教学系列之——Django入门(一)【不需知道web框架】
查看>>
Linux学习-标准输入输出
查看>>
CentOS 7 配置IP
查看>>
文本处理工具grep及正则表达式
查看>>
Intel VT-x处于禁用状态
查看>>
用什么软件可以修改PDF文件,软件的操作方法
查看>>
如何精简企业主数据“裹脚布”
查看>>
Pointer on C
查看>>
& 号和管道符号(|)在不同场景下的使用方法
查看>>
curl 浏览器模拟请求实战
查看>>
多个VLAN中的vrrp备份组配置举例
查看>>
运维自动化之使用PHP+MYSQL+SHELL打造私有监控系统(六)
查看>>
interlib在tomcat7.0的安装
查看>>
水晶报表在大型WEB内部管理系统里的滑铁卢
查看>>
我的友情链接
查看>>
Git学习
查看>>
trove 基于 centos7 制作 mysql5.6 镜像
查看>>
结合i节点和数据块分析linux中软链接和硬链接的区别
查看>>
Heartbeat crm的配置
查看>>
Stream
查看>>