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次数据,然后结束全部进程。
相关推荐
YENCSDN 2020-11-17
lsjweiyi 2020-11-17
houmenghu 2020-11-17
Erick 2020-11-17
HeyShHeyou 2020-11-17
以梦为马不负韶华 2020-10-20
lhtzbj 2020-11-17
夜斗不是神 2020-11-17
pythonjw 2020-11-17
dingwun 2020-11-16
lhxxhl 2020-11-16
坚持是一种品质 2020-11-16
染血白衣 2020-11-16
huavhuahua 2020-11-20
meylovezn 2020-11-20
逍遥友 2020-11-20
weiiron 2020-11-16