使用os.O_NONBLOCK模式时，如何等待IO读写操作完成？

首先得澄清一个点：当你给普通本地文件加上os.O_NONBLOCK标志时，这个模式的实际作用其实很有限。本地文件系统的读写大多会被内核缓存，所以哪怕你用非阻塞模式打开，os.write或者os.read通常还是会立即返回——但这不代表数据已经真正落到磁盘上，只是进入了内核缓存而已。如果是管道、套接字这类IPC对象，非阻塞模式才会出现“操作未完成就返回”的情况（比如抛出BlockingIOError）。

回到你的需求：要确保当前读写操作完成后再进行下一次操作，分两种场景来解决：

1. 确保数据已持久化到磁盘 #

如果你的核心需求是让之前的写入真正落到磁盘（而不是停留在内核缓存），那么用os.fsync()或者os.fdatasync()就可以：

• os.fsync(fd)：强制把文件描述符fd对应的所有缓存数据（包括元数据，比如文件大小、修改时间）刷新到磁盘，调用完成后就能确定之前的写入已经完全持久化。
• os.fdatasync(fd)：只刷新文件的数据部分，不更新元数据，性能比fsync更好，适合只关心数据安全、不需要同步元数据的场景。

举个简单的例子：

import os

fd = os.open("test.txt", os.O_CREAT | os.O_WRONLY | os.O_NONBLOCK)
os.write(fd, b"hello world")
# 确保数据写入磁盘
os.fsync(fd)
# 现在可以安全地进行后续读写操作了
os.close(fd)

2. 处理真正的非阻塞IO未完成场景（比如管道/套接字） #

如果是针对管道、套接字这类会真的出现“非阻塞操作无法立即完成”的对象（比如调用os.write抛出BlockingIOError），那么你需要用IO多路复用工具来等待文件描述符进入可操作状态：

• 用select.select()：监听文件描述符的可读/可写状态，直到它可以进行操作再执行读写。
• 或者select.poll()：功能类似，但更适合处理大量文件描述符的场景。

比如处理非阻塞写的例子：

import os
import select

path_to_pipe = "my_pipe"
# 创建并打开非阻塞管道
os.mkfifo(path_to_pipe)
fd = os.open(path_to_pipe, os.O_WRONLY | os.O_NONBLOCK)

data_to_write = b"this is a long message that might not write all at once"

while data_to_write:
    # 等待fd变为可写，设置5秒超时
    writable, _, _ = select.select([], [fd], [], 5)
    if fd in writable:
        try:
            written = os.write(fd, data_to_write)
            # 去掉已经写入的部分
            data_to_write = data_to_write[written:]
        except BlockingIOError:
            # 还是无法写入，继续等待
            continue
    else:
        raise TimeoutError("Waited too long for pipe to be writable")

# 写入完成，进行后续操作
os.close(fd)
os.unlink(path_to_pipe)

额外提醒 #

os.wait()确实只适用于子进程的等待，和IO操作完全是两回事。另外，如果你的目标是实现异步IO，其实Python有更高层的API可以用，比如asyncio配合aiofiles，比直接操作os.open的非阻塞模式要更简洁、更易维护。

内容的提问来源于stack exchange，提问作者steve