#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 進程共享數據(數據傳輸)實例