Method PikaDispatchThread

src/pika_dispatch_thread.cc:17–22

extern PikaServer* g_pika_server;

PikaDispatchThread::PikaDispatchThread(std::set<std::string>& ips, int port, int work_num, int cron_interval,
                                       int queue_limit, int max_conn_rbuf_size)
    : conn_factory_(max_conn_rbuf_size), handles_(this) {
  thread_rep_ = net::NewDispatchThread(ips, port, work_num, &conn_factory_, cron_interval, queue_limit, &handles_);
  thread_rep_->set_thread_name("Dispatcher");
}

PikaDispatchThread::~PikaDispatchThread() {
  thread_rep_->StopThread();