Method ThreadLoop

core/predictor/framework/request_cache.cpp:180–202

}

void RequestCache::ThreadLoop() {
  std::queue<std::pair<uint64_t, std::shared_ptr<Response>>> exec_task_queue;
  for (;;) {
    {
      std::unique_lock<std::mutex> lock(queue_mutex_);
      condition_.wait(
          lock, [this]() { return this->bstop_ || this->task_queue_.size(); });

      if (!task_queue_.size()) {
        if (bstop_) {
          return;
        }
        continue;
      }
      swap(exec_task_queue, task_queue_);
    }
    while (!exec_task_queue.empty()) {
      auto [key, res_ptr] = exec_task_queue.front();
      exec_task_queue.pop();
      PutImpl(*res_ptr, key);
    }
  }
}

int RequestCache::AddTask(uint64_t key, const Response& res) {
  std::unique_lock<std::mutex> lock(queue_mutex_);