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

2019-12-22 14:54:12 阅读：244 来源： 互联网

标签：__ python self 编程数据共享 Pipe close conn2 conn1

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次数据，然后结束全部进程。

标签：__,python,self,编程,数据共享,Pipe,close,conn2,conn1
来源： https://www.cnblogs.com/wangdianchao/p/12079780.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

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