如何通过epollselect封装实现高效异步事件循环的源码分析？

本文共计1153个文字，预计阅读时间需要5分钟。

在Linux的高并发场景下，`select`的效率瓶颈十分明确：

实操建议：

• epoll_create1(EPOLL_CLOEXEC) 替代 epoll_create，避免 fork 后子进程意外继承句柄
• 始终用 EPOLLET（边缘触发）+ 非阻塞 socket，否则一次就绪可能漏读完所有数据
• 不要在 epoll_wait 返回后反复 read/write 直到 EAGAIN，必须配合 while (true) { ... break on EAGAIN } 循环
• 注册 EPOLLIN | EPOLLET 即可，不需要额外加 EPOLLONESHOT——你自己控制读写状态更清晰

epoll_event 结构体里哪些字段真正在循环中被频繁读写

epoll_event.data.ptr 是唯一推荐存放用户上下文的地方，比如指向你封装的 Connection 对象指针；epoll_event.data.fd 只在监听 socket 场景下有用（如 accept），普通连接应避免依赖它——因为 fd 可能被复用（close + new socket），而 ptr 是稳定的。

常见错误现象：epoll_ctl(EPOLL_CTL_ADD) 时把栈变量地址赋给 ptr，之后该变量生命周期结束，回调时解引用直接 crash。

立即学习“C++免费学习笔记（深入）”；

实操建议：

• 所有注册到 epoll 的对象（socket、timer、signal handler）必须堆分配，且由事件循环统一管理生命周期
• 不要把 std::shared_ptr 直接存进 ptr（会引发 double-free 或悬挂），改用裸指针 + 引用计数或 owner 标记
• epoll_event.events 字段只在注册/修改时设置，epoll_wait 返回时不更新它——它只是你当初告诉内核“关心什么事件”，不是运行时状态

如何让事件循环真正支持非阻塞定时器和信号处理

纯 epoll 不处理时间或信号，得靠 timerfd_create 和 signalfd 两个 Linux 特有机制把它们转成可 epoll 等待的 fd。这是高性能封装的关键一环，否则只能靠 busy-loop 或低效的 alarm + sigwait。

使用场景：HTTP 连接空闲超时、心跳包重发、配置热重载（SIGHUP）、平滑退出（SIGTERM）。

实操建议：

• 用 timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK) 创建定时器 fd，然后 timerfd_settime 设置首次触发时间，再 epoll_ctl(EPOLL_CTL_ADD) 注册 EPOLLIN
• 收到 timerfd 就绪后，务必 read(&exp, sizeof(uint64_t)) 清空就绪计数，否则下次 epoll_wait 立刻返回
• signalfd 前必须先 sigprocmask 屏蔽目标信号（如 SIGUSR1），否则信号仍可能以传统方式中断系统调用
• 不要在一个事件循环里混用 std::this_thread::sleep_for——它会让整个循环阻塞，破坏异步语义

为什么你的 epoll_wait 总是返回 0 或卡住

返回 0 表示 timeout 到期，但如果你传的是 -1（无限等待），那基本是 fd 没注册成功或注册后被意外关闭；卡住则大概率是某个 socket 没设成非阻塞模式，导致 read/write 在 ET 模式下阻塞了整个循环。

最容易被忽略的点：监听 socket（listen fd）本身也要设为非阻塞。否则 accept 在连接洪峰时可能阻塞，后续所有事件都被拖住。

调试建议：

• 每次 epoll_ctl 后检查返回值，打印 errno（如 ENOENT 表示 fd 已关闭，EEXIST 表示重复添加）
• 用 strace -e trace=epoll_wait,epoll_ctl,accept,read,write 观察实际系统调用序列
• 在 epoll_wait 前加 clock_gettime(CLOCK_MONOTONIC, &start)，返回后算耗时，>10ms 就要查是不是有慢系统调用没规避掉

真正的难点不在封装接口，而在确保每个 fd 的状态机（就绪→处理→再次等待）和内存生命周期完全对齐。少一个 EPOLLET 标志，或漏一次 read 直到 EAGAIN，都可能让连接静默丢包或 CPU 拉满。这些细节不会报错，只会等压测时才浮现。