REDIS事件之EventLoop

Posted 2021-09-13 Leonly

什么是EventLoop

单线程只能顺序处理任务，如果某个任务阻塞(IO操作)，会导致后续任务处理延迟。

任务可以分成两种，一种是同步任务（synchronous），另一种是异步任务（asynchronous）。同步任务指的是，在主线程上排队执行的任务，只有前一个任务执行完毕，才能执行后一个任务；异步任务指的是，不进入主线程、而进入"任务队列"（task queue）的任务，只有"任务队列"通知主线程，某个异步任务可以执行了，该任务才会进入主线程执行。

具体来说，异步执行的运行机制如下。

（1）所有同步任务都在主线程上执行，形成一个执行栈（execution context stack）。
（2）主线程之外，还存在一个"任务队列"（task queue）。只要异步任务有了运行结果，就在"任务队列"之中放置一个事件。
（3）一旦"执行栈"中的所有同步任务执行完毕，系统就会读取"任务队列"，看看里面有哪些事件。那些对应的异步任务，于是结束等待状态，进入执行栈，开始执行。
（4）主线程不断重复上面的第三步。

redis的事件循环

redis启动后初始化工作结束后，即进入等待任务的循环过程中。

ae.c/aeMain函数

void aeMain(aeEventLoop *eventLoop) {
  while (!eventLoop->stop) {
    aeProcessEvents(eventLoop, AE_ALL_EVENTS);
  }
}

这个有个aeEventLoop对象，是在循环中传递的对象，

ae.h/aeEventLoop

struct aeEventLoop {
    int stop; // 标识循环是否继续
    void *apidata; // io事件数据，见ae_epoll.c/aeApiState
    struct aeFileEvent *events; // 注册事件列表，见ae.h/aeFileEvent
    struct aeFileEvent *fired; // 触发的事件列表
}

ae.h/aeFileEvent

struct aeFileEvent {
    int mask; // one of AE_(READABLE|WRITABLE)，事件类型
    aeFileProc *rfileProc; // READABLE事件处理器
    aeFileProc *wfileProc; // WRITABLE事件处理器
    void *clientData; // 客户端数据
}