python 多进程管道 消息式通信

举报
风吹稻花香 发表于 2021/06/05 01:33:18 2021/06/05
【摘要】   from multiprocessing import Process,Pipe # 导入进程,管道模块 def f(conn):     conn.send([1,'test',None])     conn.send([2,'test',None])     print(conn.recv())...

 

from multiprocessing import Process,Pipe
# 导入进程,管道模块

def f(conn):
    conn.send([1,'test',None])
    conn.send([2,'test',None])
    print(conn.recv())
    conn.close()

if __name__ == "__main__":
    parent_conn,child_conn = Pipe() #产生两个返回对象,一个是管道这一头,一个是另一头
    p = Process(target=f,args=(child_conn,))
    p.start()
    print(parent_conn.recv())
    print(parent_conn.recv())
    parent_conn.send('father test')
    p.join()

 

管道通信性能测试,传输图片需要3ms左右,与多进程差不多。


  
  1. # !/usr/bin/env python
  2. # -*- coding: utf-8 -*-
  3. import multiprocessing
  4. import random
  5. import time
  6. import os
  7. from multiprocessing import Pipe
  8. import cv2
  9. class producer(multiprocessing.Process):
  10. def __init__(self, queue,parent_conn):
  11. multiprocessing.Process.__init__(self

文章来源: blog.csdn.net,作者:网奇,版权归原作者所有,如需转载,请联系作者。

原文链接:blog.csdn.net/jacke121/article/details/87566186

【版权声明】本文为华为云社区用户转载文章,如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

举报
请填写举报理由
0/200