Method GetThrd

oneflow/core/thread/thread_manager.cpp:32–36

}

Thread* ThreadMgr::GetThrd(int64_t thrd_id) {
  auto iter = threads_.find(thrd_id);
  CHECK(iter != threads_.end()) << " Thread: " << thrd_id << " not found";
  return iter->second.get();
}

void ThreadMgr::AddThreads(const HashSet<int64_t>& thread_ids) {
  const int64_t this_rank = GlobalProcessCtx::Rank();