multiprocessing.Pipe() 的更多用法

除了基本的进程间通信功能，`multiprocessing.Pipe()` 还有一些其他的用法。

1. 单向通信：默认情况下，`multiprocessing.Pipe()` 创建的管道是双向的，即父进程和子进程都可以发送和接收数据。如果你只需要单向通信，可以通过设置 `duplex=False` 参数来创建单向管道。

from multiprocessing import Process, Pipe

# 子进程函数
def child_process(conn):
    data = conn.recv()
    print("子进程接收到的数据：", data)

# 创建单向管道
parent_conn, child_conn = Pipe(duplex=False)

# 创建子进程
p = Process(target=child_process, args=(child_conn,))
p.start()

# 父进程发送数据
data = "Hello, child process!"
parent_conn.send(data)

p.join()

2. 非阻塞通信：默认情况下，`recv()` 方法在没有数据可读时会阻塞等待，直到有数据可读才会返回。如果你希望在没有数据时立即返回，可以使用 `poll()` 方法来检查是否有数据可读。

from multiprocessing import Process, Pipe

# 父进程函数
def parent_process(conn):
    if conn.poll():
        data = conn.recv()
        print("父进程接收到的数据：", data)

# 创建管道
parent_conn, child_conn = Pipe()

# 创建子进程
p = Process(target=parent_process, args=(parent_conn,))
p.start()

# 父进程发送数据
data = "Hello, child process!"
child_conn.send(data)

p.join()

3. 超时等待：如果你希望在一定时间内等待数据，可以使用 `recv()` 方法的 `timeout` 参数来设置超时时间。

from multiprocessing import Process, Pipe

# 子进程函数
def child_process(conn):
    try:
        data = conn.recv(timeout=5)
        print("子进程接收到的数据：", data)
    except:
        print("子进程在超时时间内没有接收到数据。")

# 创建管道
parent_conn, child_conn = Pipe()

# 创建子进程
p = Process(target=child_process, args=(child_conn,))
p.start()

# 父进程不发送数据

p.join()

以上是 `multiprocessing.Pipe()` 的一些更多用法，希望对你有所帮助。如果还有其他问题，请随时提问。