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

1.管道

from multiprocessing import Pipe

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

结果：~双向通信

2.在进程中传递数据

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

结果：输出10次数据，然后结束全部进程。