如何在无缓冲的情况下读取子进程管道

import os
import fcntl

# 创建管道
r, w = os.pipe()

# 设置管道读端为非阻塞模式
fcntl.fcntl(r, fcntl.F_SETFL, os.O_NONBLOCK)

# 创建子进程
pid = os.fork()

if pid == 0:
    # 子进程中写入数据到管道
    os.close(r)
    os.write(w, b"Hello, parent process!")
    os.close(w)
else:
    # 父进程中读取数据
    os.close(w)
    data = b""
    while True:
        try:
            chunk = os.read(r, 1024)
            if not chunk:
                break
            data += chunk
        except BlockingIOError:
            continue
    os.close(r)
    print(data.decode())