Python multiprocessing模块中的Pipe管道使用实例

multiprocessing.Pipe([duplex])
返回2个连接对象(conn1, conn2),代表管道的两端,默认是双向通信.如果duplex=False,conn1只能用来接收消息,conn2只能用来发送消息.不同于os.open之处在于os.pipe()返回2个文件描述符(r, w),表示可读的和可写的

实例如下:

#!/usr/bin/python

#coding=utf-8

import os

from multiprocessing import Process, Pipe

def send(pipe):

 pipe.send(['spam'] + [42, 'egg'])

 pipe.close()
def talk(pipe):

 pipe.send(dict(name = 'Bob', spam = 42))

 reply = pipe.recv()

 print('talker got:', reply)
if __name__ == '__main__':

 (con1, con2) = Pipe()

 sender = Process(target = send, name = 'send', args = (con1, ))

 sender.start()

 print "con2 got: %s" % con2.recv()#从send收到消息

 con2.close()
 (parentEnd, childEnd) = Pipe()

 child = Process(target = talk, name = 'talk', args = (childEnd,))

 child.start()

 print('parent got:', parentEnd.recv())

 parentEnd.send({x * 2 for x in 'spam'})

 child.join()

 print('parent exit')

输出如下:

con2 got: ['spam', 42, 'egg']

('parent got:', {'name': 'Bob', 'spam': 42})

('talker got:', set(['ss', 'aa', 'pp', 'mm']))

parent exit

以上就是Python multiprocessing模块中的Pipe管道使用实例。有志者，事竞成，破釜沉舟百二秦关终归楚；苦心人，天不负，卧薪尝胆三千越甲可吞吴。更多关于Python multiprocessing模块中的Pipe管道使用实例请关注haodaima.com其它相关文章！