Pythonmultiprocessing模塊中的Pipe管道使用實(shí)例

來源：懂視網(wǎng) 責(zé)編：小采時間：2020-11-27 14:32:29

Pythonmultiprocessing模塊中的Pipe管道使用實(shí)例

Pythonmultiprocessing模塊中的Pipe管道使用實(shí)例:multiprocessing.Pipe([duplex]) 返回2個連接對象(conn1, conn2),代表管道的兩端,默認(rèn)是雙向通信.如果duplex=False,conn1只能用來接收消息,conn2只能用來發(fā)送消息.不同于os.open之處在于os.pipe()返回2個文件描述符(r, w),表示可讀的和

推薦度：

點(diǎn)擊下載本文 文檔為doc格式

導(dǎo)讀Pythonmultiprocessing模塊中的Pipe管道使用實(shí)例:multiprocessing.Pipe([duplex]) 返回2個連接對象(conn1, conn2),代表管道的兩端,默認(rèn)是雙向通信.如果duplex=False,conn1只能用來接收消息,conn2只能用來發(fā)送消息.不同于os.open之處在于os.pipe()返回2個文件描述符(r, w),表示可讀的和

multiprocessing.Pipe([duplex])
返回2個連接對象(conn1, conn2),代表管道的兩端,默認(rèn)是雙向通信.如果duplex=False,conn1只能用來接收消息,conn2只能用來發(fā)送消息.不同于os.open之處在于os.pipe()返回2個文件描述符(r, w),表示可讀的和可寫的

實(shí)例如下:
代碼如下:

#!/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

聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com