python3 进程间通信（python进程之间如何通信）

本文教程操作环境：windows7系统    
    
    
、Python 3.9.1   
    
    
  ，DELL G3电脑   
    
    
  。

1    


     


     


  、思路

Process之间肯定是需要通信的


     


     


     
，操作系统提供了很多机制来实现进程间的通信


     


     


     
。Python的multiprocessing模块包装了底层的机制 




 




 




，提供了Queue




 




 




 
、Pipes等多种方式来交换数据 




 




 




。

2   

   

   

、实例

以Queue为例   

   

   

 ，在父进程中创建两个子进程

     

     

     ，一个往Queue里写数据
  




  




  




，一个从Queue里读数据   

   

   

 。

frommultiprocessingimportProcess,Queue importos,time,random #写数据进程执行的代码: defwrite(q): print(Processtowrite:%s%os.getpid()) forvaluein[A,B,C]: print(Put%stoqueue...%value) q.put(value) time.sleep(random.random()) #读数据进程执行的代码: defread(q): print(Processtoread:%s%os.getpid()) whileTrue: value=q.get(True) print(Get%sfromqueue.%value) if__name__==__main__: #父进程创建Queue  


  


  


，并传给各个子进程： q=Queue() pw=Process(target=write,args=(q,)) pr=Process(target=read,args=(q,)) #启动子进程pw 
     
     
     ，写入: pw.start() #启动子进程pr

   




   




   



，读取: pr.start() #等待pw结束: pw.join() #pr进程里是死循环 



 



 



，无法等待其结束                ，只能强行终止: pr.terminate()