#coding:utf-8'''Created on 2017年11月22日@author: li.liu'''import multiprocessingfrom time import sleepdef 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