Python多进程-进程间数据的传递
2024-10-15 03:07:54
两个进程间的数据是独立的,要进行数据传递的话可通过几个方法
Queue
通过队列来进行进程间数据的传递
# -*- coding:utf-8 -*-
__author__ = "MuT6 Sch01aR" from multiprocessing import Process, Queue def Child_Process(n):
n.put("Data From Child Process") if __name__ == '__main__':
q = Queue()
p = Process(target=Child_Process, args=(q,))
p.start()
print(q.get())
p.join()
运行结果
父进程中声明了一个queue,也生成了一个子进程,然后父进程把queue克隆一份,然后通过pickle序列化queue,再把queue进行pickle反序列化传入子进程
两个进程之间通过进程queue进行数据传递需要经过pickle的序列化和反序列化
Pipe
通过管道来进行进程间数据的传递
# -*- coding:utf-8 -*-
__author__ = "MuT6 Sch01aR" from multiprocessing import Process, Pipe def f(conn):
conn.send("Data_1 from Conn_1")
conn.send("Data_2 from Conn_1")
print("Conn_1: ",conn.recv())
conn.close() if __name__ == '__main__':
conn_1, conn_2 = Pipe() #生成管道的两边,分别传给两个进程
p = Process(target=f, args=(conn_1,))
p.start()
print("Conn_2: ",conn_2.recv())
print("Conn_2: ",conn_2.recv())
conn_2.send("Data_1 from Conn_2")
p.join()
运行结果
上面是两边的管道收发数据的次数一样,如果把conn_2给conn_1发送数据的那一行代码去掉
脚本就会在conn_1接收数据处一直等着
最新文章
- 【转】 App架构设计经验谈:接口的设计
- C++ - 静态成员函数
- Centos7设置关闭防火墙
- Android日常开发总结的技术经验60条 转
- ecshop商品-》购买记录
- paper 69:Haar-like矩形遍历检测窗口演示Matlab源代码[转载]
- 安装arbotix simulator仿真环境--9
- RMAN备份失败之:mount: block device /dev/emcpowerc1 is write-protected, mounting read-only
- [转] Asp.net Report Viewer 简单实例
- Spring源码入门——AnnotationBeanNameGenerator解析
- request和response的中文乱码问题
- python logging模块使用
- LightOJ - 1422 Halloween Costumes (区间dp)
- qt学习:信号,槽
- POJ 1475 Pushing Boxes 搜索- 两重BFS
- OpenSUSE 13.2安装Texlive2014+Texmaker+Lyx
- C++ 头文件系列(stack)
- sql注入之一次艰难的绕过-三层防护(oracle)
- 值得 .NET 开发者了解的15个特性
- python接口自动化(二十五)--unittest断言——下(详解)