Python 进程共享数据(数据传输)实例

Posted 2020-10-18 文刀文刀

 

#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