創(chuàng)建管道的類：

Pipe([duplex]):在進(jìn)程之間創(chuàng)建一條管道，并返回元組(conn1,conn2),其中conn1，conn2表示管道兩端的連接對(duì)象，強(qiáng)調(diào)一點(diǎn)：必須在產(chǎn)生Process對(duì)象之前產(chǎn)生管道

參數(shù)介紹：

dumplex:默認(rèn)管道是全雙工的，如果將duplex射成False，conn1只能用于接收，conn2只能用于發(fā)送。

frommultiprocessingimportProcess,Pipe

importtime,os

defconsumer(p,name):

left,right=p

left.close()

whileTrue:

try:

baozi=right.recv()

print('%s收到包子:%s'%(name,baozi))

exceptEOFError:

right.close()

break

defproducer(seq,p):

left,right=p

right.close()

foriinseq:

left.send(i)

#time.sleep(1)

else:

left.close()

if__name__=='__main__':

left,right=Pipe()

c1=Process(target=consumer,args=((left,right),'c1'))

c1.start()

seq=(iforiinrange(10))

producer(seq,(left,right))

right.close()

left.close()

c1.join()

print('主進(jìn)程')

注意：生產(chǎn)者和消費(fèi)者都沒有使用管道的某個(gè)端點(diǎn)，就應(yīng)該將其關(guān)閉，如在生產(chǎn)者中關(guān)閉管道的右端，在消費(fèi)者中關(guān)閉管道的左端。如果忘記執(zhí)行這些步驟，程序可能再消費(fèi)者中的recv()操作上掛起。管道是由操作系統(tǒng)進(jìn)行引用計(jì)數(shù)的,必須在所有進(jìn)程中關(guān)閉管道后才能生產(chǎn)EOFError異常。因此在生產(chǎn)者中關(guān)閉管道不會(huì)有任何效果，付費(fèi)消費(fèi)者中也關(guān)閉了相同的管道端點(diǎn)。

管道可以用于雙向通信，利用通常在客戶端/服務(wù)器中使用的請(qǐng)求/響應(yīng)模型或遠(yuǎn)程過程調(diào)用，就可以使用管道編寫與進(jìn)程交互的程序

frommultiprocessingimportProcess,Pipe

importtime,os

defadder(p,name):

server,client=p

client.close()

whileTrue:

try:

x,y=server.recv()

exceptEOFError:

server.close()

break

res=x+y

server.send(res)

print('serverdone')

if__name__=='__main__':

server,client=Pipe()

c1=Process(target=adder,args=((server,client),'c1'))

c1.start()

server.close()

client.send((10,20))

print(client.recv())

client.close()

c1.join()

print('主進(jìn)程')

#注意：send()和recv()方法使用pickle模塊對(duì)對(duì)象進(jìn)行序列化。

以上內(nèi)容為大家介紹了python管道，希望對(duì)大家有所幫助，如果想要了解更多Python相關(guān)知識(shí)，請(qǐng)關(guān)注IT培訓(xùn)機(jī)構(gòu):千鋒教育。