Reactor/Epoll为什么可以高性能？

在 Reactor 模式中使用 epoll_wait 实现低 CPU 占用率的核心原理是 ​事件驱动的阻塞等待机制，而非忙等待。以下通过分步骤解析其工作原理和性能优势：

void network_thread() {
    int epoll_fd = epoll_create1(0);
    epoll_event events[MAX_EVENTS];
    
    // 添加UDP socket到epoll
    epoll_ctl(epoll_fd, EPOLL_CTL_ADD, udp_sock, &event);

    while (!stopped) {
        // 阻塞等待事件（非忙等待）
        int n = epoll_wait(epoll_fd, events, MAX_EVENTS, -1);
        for (int i = 0; i < n; i++) {
            // 接收UDP数据包
            recvfrom(udp_sock, buffer, sizeof(buffer), 0, &src_addr, &addrlen);
            // 解码并推送到队列
            decode_and_push(buffer);
        }
    }
}

​一、epoll_wait 的工作机制

​1. 阻塞式等待

• ​函数签名：int epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout);
• ​关键参数：timeout = -1 表示无限等待，直到有事件发生。
• ​行为：
  • 当没有网络事件时，调用线程被操作系统挂起​（进入睡眠状态）。
  • 当网卡接收到数据包时，内核通过硬件中断唤醒线程。

​2. 事件通知流程

sequenceDiagram
    participant 网卡
    participant 内核
    participant 用户线程

    网卡->>内核: 收到数据包（触发中断）
    内核->>用户线程: 唤醒因epoll_wait阻塞的线程
    用户线程->>用户线程: 处理数据包（recvfrom等）

​二、与忙等待的对比

​1. 忙等待模式（高CPU占用）​

// 伪代码示例：CPU占用率100%
while (!stopped) {
    if (has_data(udp_sock)) { // 主动轮询检查
        recvfrom(...);
        process(...);
    }
}

• ​问题：has_data() 需要反复执行系统调用或内存检查，导致CPU空转。

​2. Reactor模式（低CPU占用）​

// 伪代码示例：CPU空闲时占用0%
while (!stopped) {
    int n = epoll_wait(...); // 阻塞等待事件
    for (int i=0; i<n; i++) { // 仅处理就绪事件
        recvfrom(...);
        process(...);
    }
}

• ​优势：无事件时线程不消耗CPU周期。

​三、性能关键点

​1. 用户态与内核态协作

• ​事件注册：通过 epoll_ctl 将 socket 注册到 epoll 实例。
• ​事件触发：内核维护一个就绪队列​（ready list），仅当数据到达时才会将事件加入队列。
• ​零拷贝优化：现代网卡支持 DMA 直接将数据写入内存，减少内核到用户态的数据拷贝。

​2. 时间复杂度对比

​四、底层实现细节

​1. epoll 的三层结构

​2. 性能优化技术

• ​边缘触发（ET）​：事件仅在状态变化时通知一次（比水平触发更高效）。
• ​EPOLLONESHOT：事件处理后需重新注册，避免惊群效应。
• ​SO_REUSEPORT：多线程绑定相同端口，提升吞吐量。

​五、实测数据

​1. 单线程处理能力

​2. 延迟分布

​六、总结

• ​低CPU占用本质：通过操作系统调度器实现的线程阻塞-唤醒机制，避免无事件时的CPU空转。
• ​高性能根源：
  1. ​事件驱动：仅处理有效数据，跳过空轮询。
  2. ​内核优化：就绪队列和红黑树实现O(1)事件检测。
  3. ​硬件协作：网卡中断与DMA降低CPU负载。
• ​适用场景：高频交易、实时通信、物联网等高并发低延迟场景。