C++如何实现一个事件循环（Event Loop）？C++异步IO模型实战【网络编程】

C++事件循环核心是单线程基于epoll等IO多路复用机制监听fd就绪并触发回调，包含IO监视器、事件注册和分发主循环三部分，支持add_read、run、stop等接口。

在C++中实现事件循环，核心是**用一个线程持续监听多个文件描述符（如socket）的就绪状态，并在就绪时触发对应回调**。它不依赖协程或第三方运行时（如Boost.Asio的隐藏调度器），而是基于操作系统原生IO多路复用机制（epoll（Linux）、kqueue（macOS/BSD）、select（通用但低效））构建轻量、可控的异步IO骨架。

1. 事件循环的基础结构设计

一个最小可用的事件循环需包含三部分：IO监视器（如epoll实例）、待注册的事件（fd + 读/写 + 回调）、事件分发主循环。不封装成类也行，但建议用类管理资源生命周期：

• 构造时创建epoll_fd（Linux）或等价句柄
• 提供add_fd(int fd, uint32_t events, std::function<void> cb)</void>注册fd与事件类型（EPOLLIN / EPOLLOUT）及就绪回调
• 提供run()进入阻塞等待，每次epoll_wait()返回后遍历就绪列表并执行对应回调
• 支持stop()通过向epoll添加一个自管道（eventfd或pipe）来中断阻塞

2. 使用epoll实现可运行的简易EventLoop（Linux）

以下是一个去掉异常处理和日志的精简版，重点展示逻辑主线：

class EventLoop {
  int epoll_fd_;
  std::unordered_map<int, std::function<void()>> callbacks_;

public:
  EventLoop() : epoll_fd_(epoll_create1(0)) {
    if (epoll_fd_ == -1) abort();
  }

  void add_read(int fd, std::function<void()> cb) {
    struct epoll_event ev{};
    ev.events = EPOLLIN | EPOLLET; // 边沿触发更高效
    ev.data.fd = fd;
    callbacks_[fd] = std::move(cb);
    epoll_ctl(epoll_fd_, EPOLL_CTL_ADD, fd, &ev);
  }

  void run() {
    const int MAX_EVENTS = 64;
    struct epoll_event events[MAX_EVENTS];

    while (true) {
      int nfds = epoll_wait(epoll_fd_, events, MAX_EVENTS, -1);
      if (nfds == -1 && errno == EINTR) continue;

      for (int i = 0; i < nfds; ++i) {
        int fd = events[i].data.fd;
        if (callbacks_.count(fd)) {
          callbacks_[fd](); // 执行用户注册的读就绪回调
        }
      }
    }
  }
};

登录后复制

注意：实际项目中需处理EPOLLHUP/EPOLLERR、支持写事件注册、支持移除fd（EPOLL_CTL_DEL）、避免回调中长时间阻塞（否则卡住整个loop）。

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

标签： linux 操作系统 mac ai c++ macos 网络编程 用户注册 cos red