管道通信在多进程的使用

Question

下面是源代码，我想问下为什么管道通信不成功

import time
from multiprocessing import Process, Pipe
import threading

def f3(conn_1,conn_2):
    thread0 = threading.Thread(target=f, args=(conn_1,conn_2,))
    thread0.setDaemon(True)
    thread0.start()

def f(conn_1,conn_2):
    conn_2.close()
    conn_1.send(1)
    conn_1.close()

def f1(conn_1,conn_2):

    conn_1.close()
    print("Conn_2: ", conn_2.recv())
    conn_2.close()

if __name__ == '__main__':
    conn_1, conn_2 = Pipe()  # 生成管道的两边，分别传给两个进程
    p = Process(target=f3, args=(conn_1,conn_2))
    p.start()
    thread0 = threading.Thread(target=f1, args=(conn_1,conn_2,))
    thread0.setDaemon(True)
    thread0.start()

Answer 1

1、需要确保进程和线程都已经正确启动，才能进行进程间通信。可以使用join()方法阻塞当前线程，等待进程和线程完成执行。
2、需要注意管道的方向，即数据的读取和写入方式。在这个例子中，你在f()函数中关闭了conn_2，但在f1()函数中尝试从conn_2接收数据，这可能会导致管道通信失败。

import time
from multiprocessing import Process, Pipe
import threading
 
def f3(conn_1, conn_2):
    thread0 = threading.Thread(target=f, args=(conn_1, conn_2,))
    thread0.setDaemon(True)
    thread0.start()
 
def f(conn_1, conn_2):
    conn_2.close()
    conn_1.send(1)
    conn_1.close()
 
def f1(conn_1, conn_2):
    conn_2.close()
    print("Conn_1: ", conn_1.recv())
    conn_1.close()
 
if __name__ == '__main__':
    conn_1, conn_2 = Pipe()
    p = Process(target=f3, args=(conn_1, conn_2,))
    p.start()
    thread0 = threading.Thread(target=f1, args=(conn_1, conn_2,))
    thread0.setDaemon(True)
    thread0.start()
    p.join()
    thread0.join()