python中multiprocessing模块之Pipe管道

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

实例如下:

osfrom multiprocessing import Process, Pipe:pipe.send([‘spam’] + [42, ‘egg’])pipe.close():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 * })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

，以诚感人者，人亦诚而应。