最核⼼的部分就是 EventLoop 、 Channel 以及 Poller 三个类，其中 EventLoop 可以看作是对业务线程的封装，⽽ Channel 可以看作是对每个已经建⽴连接的封装（即 accept(3) 返回的⽂件描述符）

 EventLoop

class EventLoop {
public:typedef std::function<void()> Function;// 初始化poller, event_fd，给 event_fd 注册到 epoll 中并注册其事件处理回调EventLoop();~EventLoop();// 开始事件循环 调⽤该函数的线程必须是该 EventLoop 所在线程，也就是 Loop 函数不能跨线程调⽤void Loop();// 停⽌ Loopvoid StopLoop();// 如果当前线程就是创建此EventLoop的线程 就调⽤callback(关闭连接 EpollDel) 否则就放⼊等待执⾏
函数区void RunInLoop(Function&& func);// 把此函数放⼊等待执⾏函数区 如果当前是跨线程 或者正在调⽤等待的函数则唤醒void QueueInLoop(Function&& func);// 把fd和绑定的事件注册到epoll内核事件表void PollerAdd(std::shared_ptr<Channel> channel, int timeout = 0);// 在epoll内核事件表修改fd所绑定的事件void PollerMod(std::shared_ptr<Channel> channel, int timeout = 0);// 从epoll内核事件表中删除fd及其绑定的事件void PollerDel(std::shared_ptr<Channel> channel);// 只关闭连接(此时还可以把缓冲区数据写完再关闭)void ShutDown(std::shared_ptr<Channel> channel);
代码随想录知识星球
从 EventLoop 的类定义中可以看出，除了⼀些状态量以外，每个 EventLoop 持有⼀个 Poller 的智能指针（对
epoll / poll 的封装），⼀个⽤于 EventLoop 之间通信的 Channel ，⾃⼰的线程 id，互斥锁以及装有等待处理函
数的 vector 。很明显， EventLoop 并不直接管理各个连接的 Channel （⽂件描述符的封装），⽽是通过
Poller 来进⾏的。 EventLoop 中最核⼼的函数就是 EventLoop::Loop() 。bool is_in_loop_thread();
private:// 创建eventfd 类似管道的 进程间通信⽅式static int CreateEventfd();void HandleRead(); // eventfd的读回调函数(因为event_fd写了数据，所以触发
可读事件，从event_fd读数据)void HandleUpdate(); // eventfd的更新事件回调函数(更新监听事件)void WakeUp(); // 异步唤醒SubLoop的epoll_wait(向event_fd中写⼊数据)void PerformPendingFunctions(); // 执⾏正在等待的函数(SubLoop注册EpollAdd连接套接字以
及绑定事件的函数)
private: std::shared_ptr<Poller> poller_; // io多路复⽤ 分发器int event_fd_; // ⽤于异步唤醒 SubLoop 的 Loop 函数中的
Poll(epoll_wait因为还没有注册fd会⼀直阻塞)std::shared_ptr<Channel> wakeup_channel_; // ⽤于异步唤醒的 channelpid_t thread_id_; // 线程idmutable locker::MutexLock mutex_;std::vector<Function> pending_functions_; // 正在等待处理的函数bool is_stop_; // 是否停⽌事件循环bool is_looping_; // 是否正在事件循环bool is_event_handling_; // 是否正在处理事件bool is_calling_pending_functions_; // 是否正在调⽤等待处理的函数
};

void EventLoop::Loop() {// 开始事件循环 调⽤该函数的线程必须是该EventLoop所在线程assert(!is_looping_);assert(is_in_loop_thread());is_looping_ = true;is_stop_ = false;while (!is_stop_) {// 1、epoll_wait阻塞 等待就绪事件auto ready_channels = poller_->Poll();is_event_handling_ = true;// 2、处理每个就绪事件(不同channel绑定了不同的callback)for (auto& channel : ready_channels) {channel->HandleEvents();}is_event_handling_ = false;// 3、执⾏正在等待的函数(fd注册到epoll内核事件表)PerformPendingFunctions();// 4、处理超时事件 到期了就从定时器⼩根堆中删除(定时器析构会EpollDel掉fd)poller_->HandleExpire();}is_looping_ = false;
}