本文实例讲述了Python进程的通信Queue、Pipe。分享给大家供大家参考,具体如下:
概念:进程的通信
Queue:创建与使用
Pipe:创建与使用
Queue 在multiprocessing 模块中:from multiprocessing import Queue
#Queue在multiprocessing中 from multiprocessing import Queue,Process def f(q):#要在主进程外使用,需要作为参数传入 q.put(['helloworld']) def m(q): print("get in p2:",q.get()) if __name__=="__main__": q=Queue() p=Process(target=f,args=(q,)) p.start() p2=Process(target=m,args=(q,)) p2.start()
Pipe 在multiprocessing 模块中:from multiprocessing import Pipe
from multiprocessing import Pipe,Process def f(conn): a=[1,2,3,4] conn.send(a) conn.close() def m(conn): a=conn.recv() conn.close() if __name__=="__main__": parent_conn,child_conn=Pipe()#返回两个值,第一个只能发,第二个只能收 p1=Process(target=f,args=(child_conn,)) p2 = Process(target=m, args=(parent_conn,))# p1.start() p2.start() p1.join() p2.join()
希望本文所述对大家Python程序设计有所帮助。