Method GetUpdateSparseTaskQueue

serving/processor/storage/feature_store_mgr.cc:306–313

}

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

  return &(update_task_queues_[idx]);
}

bool AsyncFeatureStoreMgr::ShouldStop() {
  return stop_;