BlockingIOError 是非阻塞IO的正常信号，表示内核暂无数据可读或缓冲区满；应通过 select 或 selectors 等机制等待就绪，而非捕获忽略或 sleep 重试。
BlockingIOError 本质是系统调用被中断，不是 Python 的 bug
遇到 BlockingIOError: [Errno 11] Resource temporarily unavailable，说明你对一个设为非阻塞模式的文件描述符（比如 socket、pipe）做了读/写操作，而内核当前没有数据可读或缓冲区已满。这不是异常需要“捕获并忽略”，而是非阻塞 IO 的正常反馈信号——它告诉你“现在不行，稍后再试”。关键不是绕过它，而是用正确机制等待就绪。
用 select.select() 手动轮询 socket 就绪状态
select.select() 是最底层、跨平台的方式，适合控制粒度要求高的场景（如单线程处理多个连接）。它不自动管理 socket 状态，需你自己维护 fd 列表和重试逻辑。
常见错误：直接在非阻塞 socket 上循环 recv() 而不先调用 select() 判断可读，导致 CPU 空转 + 频繁抛 BlockingIOError。
实操要点：
立即学习“Python免费学习笔记（深入）”；
- 调用
select.select([read_fds], [], [], timeout)前，确保所有 socket 已设为非阻塞（sock.setblocking(False)） -
timeout设为0表示非阻塞轮询；设为None会永久阻塞直到有事件；设为浮点数（如0.1）是超时等待 - 返回的
readable列表里包含可安全recv()的 socket，此时再调用不会触发BlockingIOError - 对
send()，要检查writable列表，且注意send()可能只发出部分数据，需用sendall()或手动处理返回值
import select
import socket
<p>sock = socket.socket()
sock.setblocking(False)
try:
sock.connect(('example.com', 80))
except BlockingIOError:
pass # 连接开始异步进行</p><h1>等待连接完成（可写表示 connect 完成）</h1><p>readable, writable, _ = select.select([], [sock], [], 5)
if writable:
try:
sock.getpeername() # 验证是否真的连上了
except OSError:
raise ConnectionError("connect failed")
用 selectors.DefaultSelector 替代手写 select 循环
selectors 模块是对 select、poll、kqueue、epoll 的统一封装，自动选择当前系统最优实现，并提供注册/注销/事件回调抽象。比裸用 select 更简洁，也更接近生产级代码习惯。
容易踩的坑：
- 注册前必须确保 socket 是非阻塞的，否则
selector.register()会报错 -
selector.select(timeout)返回的是(key, events)元组列表，key.fileobj才是 socket 对象，别直接拿key去 recv -
EVENT_READ和EVENT_WRITE不是互斥的，一个 socket 可能同时就绪读和写，需分别处理 - 处理完一次事件后，若还需继续监听，不用重复 register —— selector 会持续监控，除非你显式
unregister()
import selectors
import socket
<p>sel = selectors.DefaultSelector()
sock = socket.socket()
sock.setblocking(False)
try:
sock.connect(('httpbin.org', 80))
except BlockingIOError:
pass</p><h1>注册连接事件（关注可写，表示 connect 完成）</h1><p>sel.register(sock, selectors.EVENT_WRITE)</p><p>while True:
events = sel.select(timeout=5)
for key, mask in events:
if mask & selectors.EVENT_WRITE:
try:
sock.getpeername()
print("connected!")
sel.unregister(sock) # 连上后可以 unregister 或改注册为 EVENT_READ
except OSError:
print("connection failed")
break
为什么不用 time.sleep() 或重试计数器硬等？
有人试图在捕获 BlockingIOError 后加 time.sleep(0.01) 再重试，这看似简单，但实际问题很大：
- CPU 浪费：sleep 时间太短 → 频繁唤醒；太长 → 响应延迟高
- 不可靠：无法感知内核真实就绪时机，可能 sleep 过久才等到，也可能刚 sleep 完数据就到了
- 无法处理多 fd：select/selectors 天然支持同时等成百上千个 socket，sleep 方案只能串行处理
- 掩盖设计问题：真正该做的是把“等待 IO 就绪”这件事交给系统调度，而不是用户层轮询
非阻塞 IO 的核心契约是：你负责发起操作，系统负责通知你何时能继续。跳过通知环节，自己猜时间点，就等于放弃了非阻塞的意义。
真正难的不是写通一个 socket，而是当连接数涨到几百、业务逻辑混杂读写关闭时，还能让事件分发不漏、不卡、不崩——这时候 selectors 的抽象价值才凸显出来。别省那几行代码去手写状态机。
