python 多进程管道 消息式通信

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左右，与多进程差不多。

  

   

    

     

    
    

     

      # !/usr/bin/env python
     
    
   

    

     

    
    

     

      # -*- coding: utf-8 -*-
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import multiprocessing
     
    
   

    

     

    
    

     

      import random
     
    
   

    

     

    
    

     

      import time
     
    
   

    

     

    
    

     

      import os
     
    
   

    

     

    
    

     

      from multiprocessing import Pipe
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import cv2
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      class producer(multiprocessing.Process):
     
    
   

    

     

    
    

     
 def __init__(self, queue,parent_conn):
     
    
   

    

     

    
    

     

       multiprocessing.Process.__init__(self
     
    
  
 

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

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