通过队列实现进程间的通信(使用阻塞方式调用func函数)
2024-10-07 20:10:01
#_author:来童星
#date:2019/12/17
#通过队列实现进程间的通信
from multiprocessing import Pool
import os
import time
def func(name):
print('子进程(%s)执行func %s...'%(os.getpid(),name))
time.sleep(1)
if __name__=='__main__':
print('父进程(%s)'%os.getpid())
p=Pool(3)# 定义一个进程池,最大进程数为3
for i in range(10):
p.apply(func,args=(i,))# 使用阻塞方式调用func函数
print('等待所有子进程结束')
p.close()# 关闭进程池,关闭后p不再接受新的请求
p.join()# 等待子进程结束
print('所有子进程结束')
最新文章
- Markdown简单语法
- 解读sencha touch移动框架的核心架构(二)
- 统计文件种类数+获取子shell返回值的其它方法
- oracle ||,
- java web基础1Tomcat服务器基本知识
- Eclipse小技巧--快速输入System.out.println();(转)
- Nginx +keepalived
- SQL之50个常用的SQL语句
- 关于ThinkRock中的Topics
- HTML5吧
- linux中find指令与grep命令的组合使用
- AOI自动光学检测机技术在电路板检查中的应用
- drupal中使用drush命令,快速批量的开启和关闭模块
- python的模块!
- WiMAX协议栈
- 从入门到放弃,.net构建博客系统(二):依赖注入
- ●BZOJ 2560 串珠子
- k8s Kubernetes v1.10
- Spring Boot 整合Spring Security 和Swagger2 遇到的问题小结
- CSS(八)