Python 進程共享數據(數據傳輸)實例
阿新 • • 發佈:2017-12-18
進程 int style multi import def pos author 傳輸
#coding:utf-8 ‘‘‘ Created on 2017年11月22日 @author: li.liu ‘‘‘ import multiprocessing from time import sleep def m1(p,q): while True: for i in xrange(1000): print ‘發送參數:‘,i,i+1 p.send(i) q.put(i+1) sleep(3) def m2(p,q): while True: s=‘接收數據: ‘+str(p.recv())+‘ ‘+str(q.get()) print s sleep(3) if __name__==‘__main__‘: p=multiprocessing.Pipe() q=multiprocessing.Queue(5) a=multiprocessing.Process(target=m1,args=(p[0],q)) b=multiprocessing.Process(target=m2,args=(p[1],q)) a.start() b.start()
輸出
發送參數: 0 1 接收數據: 0 1 發送參數: 1 2 接收數據: 1 2
Python 進程共享數據(數據傳輸)實例