Function WorkThreadRun

serving/processor/storage/feature_store_test.cc:105–112

}

void WorkThreadRun(AsyncFeatureStoreMgr* mgr,
                   int64_t start, int64_t end) {
  for (int64_t num = start; num <= end; ++num) {
    SparseTask* task = new SparseTask();
    task->num = num;
    mgr->AddTask(task);
  }
}

}