Method GetSparseTaskQueue

serving/processor/storage/feature_store_mgr.cc:297–304

}

sparse_task_queue* AsyncFeatureStoreMgr::GetSparseTaskQueue(int idx) {
  if (idx < 0 || idx >= thread_num_) {
    LOG(FATAL) << "Error index num: " << idx
               << ", thread_num is " << thread_num_;
  }

  return &(task_queues_[idx]);
}

sparse_task_queue* AsyncFeatureStoreMgr::GetUpdateSparseTaskQueue(int idx) {
  if (idx < 0 || idx >= update_thread_num_) {