问hiredis Redis库是否为异步回调创建自己的线程

EN

#include "async.h"
#include <unistd.h>
#include <stdio.h>

void myRedisCallback(redisAsyncContext *c, void *typeless_reply, void *priv_data) {
    redisReply *r = (redisReply *)typeless_reply;
    if (r->type == REDIS_REPLY_STRING)
        printf("foo is %s\n", r->str);
}

int main() {
    redisAsyncContext *c = redisAsyncConnect("localhost", 6379);
    redisAsyncCommand(c, myRedisCallback, NULL, "GET foo");

    for (int i = 0; i < 100; i++) {
        redisAsyncHandleWrite(c); // This sends the command.
        redisAsyncHandleRead(c); // This calls the callback if the reply has been received.
        usleep(10000); // A real app would do something here.
    }

    return 0;
}

  #define MAX_EVENTS 10

  int epfd;
  if((epfd = epoll_create1(0)) == -1) {
     // handle error
  };

  redisAsyncContext *ac = redisAsyncConnect("127.0.0.1", 6379);

  if(epoll_ctl(epfd, EPOLL_CTL_ADD, ac->c.fd, &(struct epoll_event) { .events = EPOLLIN | EPOLLOUT | EPOLLET }) == -1) {
     // handle error
  }

  int nfds;
  struct epoll_event events[MAX_EVENTS];
  for(;;) {
     if((nfds = epoll_wait(epfd, events, MAX_EVENTS, -1) == -1) {
       // handle error
     }
     for(int i = 0; i < nfds; i++) {
         if(events[i].events & EPOLLIN) redisAsyncHandleRead(ac);
         if(events[i].events & EPOLLOUT) redisAsyncHandleWrite(ac);
     }
  }