python进程间管道通信失败

Question

'''
管道通信
只能用于有亲缘关系的进程
父进程中创建
'''

from  multiprocessing import Process,Pipe

#创建管道
fd1,fd2=Pipe(True)

def app1():
    print('启动app1，请登录')
    print('请求app2授权')
    fd1.send('app1请求登录')
    data=fd1.recv()
    if data:
        print('登陆成功：',data)

def app2():
    data=fd2.recv()
    print(data)
    fd2.send('123')
if __name__ == '__main__':
    p1=Process(target=app1)
    p2=Process(target=app2)
    p1.start()
    p2.start()
    p1.join()
    p2.join()

一直阻塞在这里，不知道原因
win10,python3.10

Answer 1

改下面这样，管道参数通过Process的args传入

 
'''
管道通信
只能用于有亲缘关系的进程
父进程中创建
'''
 
from  multiprocessing import Process,Pipe
 
#创建管道
fd1,fd2=Pipe(True)
 
def app1(fd1):
    print('启动app1，请登录')
    print('请求app2授权')
    fd1.send('app1请求登录')
    data=fd1.recv()
    if data:
        print('登陆成功：',data)
 
def app2(fd2):
    data=fd2.recv()
    print(data)
    fd2.send('123')
if __name__ == '__main__':
    p1=Process(target=app1,args=(fd1,))
    p2=Process(target=app2,args=(fd2,))
    p1.start()
    p2.start()
    p1.join()
    p2.join()