python_并发编程——管道和数据共享

from multiprocessing import Pipe

conn1,conn2 = Pipe()    #返回两个值
conn1.send(‘wdc‘)   #发送
print(conn2.recv()) #接收
conn2.send(‘yhf‘)
print(conn1.recv())

from multiprocessing import Pipe,Process

class Pr1(Process):
    def __init__(self,conn1):
        super().__init__()
        self.conn1 = conn1
    def run(self):
        self.conn1.send(‘吃了吗？‘)

if __name__ == ‘__main__‘:
    conn1,conn2 = Pipe()
    p = Pr1(conn1)
    p.start()
    print(conn2.recv())

from multiprocessing import Pipe,Process

class Pr1(Process):
    def __init__(self,conn1,conn2):
        super().__init__()
        self.conn1 = conn1
        self.conn2 = conn2
    def run(self):
        self.conn2.close()  #关闭conn2
        while True:
            try:
                print(self.conn1.recv())
            except EOFError:    #当其他所有的conn端口都被关闭，只剩下一个conn端口还在获取管道内的数据，而管道内已经空了的时候就会报EOFError错误。
                self.conn1.close()   #关闭conn1
                break

if __name__ == ‘__main__‘:
    conn1,conn2 = Pipe()
    p = Pr1(conn1,conn2)
    p.start()
    conn1.close()   #关闭conn1
    for i in range(10):
        conn2.send(‘吃了吗？‘)
    conn2.close()  #关闭conn2