Method AddTask

core/predictor/framework/request_cache.cpp:204–210

}

int RequestCache::AddTask(uint64_t key, const Response& res) {
  std::unique_lock<std::mutex> lock(queue_mutex_);
  std::shared_ptr<Response> res_ptr = std::make_shared<Response>(res);
  task_queue_.push(std::make_pair(key, res_ptr));
  condition_.notify_one();
  return 0;
}

bool RequestCache::Empty() {
  std::lock_guard<std::recursive_mutex> lk(cache_mtx_);