from multiprocessing import Process,Pipe
import os,time
# fd1只能recv,fd2只能send
# fd1,fd2 = Pipe(False)
# 創建一個雙向管道
fd1,fd2 = Pipe()
# fd1.close()
def fun(name):
time.sleep(1)
# 子行程發送字串到管道
fd2.send("hello "+str(name))
print(os.getppid(),"...",os.getpid())
jobs = []
for i in range(5):
p = Process(target = fun,args = (i,))
jobs.append(p)
p.start()
# 父行程從管道接受子行程發送來的訊息，發送與接受的都是字串
for i in range(5):
data = https://www.cnblogs.com/liuhaidon/p/fd1.recv()
print(data)
for i in jobs:
i.join()
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/181828.html
標籤：Python
下一篇：Python—同步和互斥