Method GetCoreIdForThread

tests/unit_test/mocks/test_environment_state.cpp:76–97

}

auto TestEnvironmentState::GetCoreIdForThread(std::thread::id tid) -> size_t {
  std::lock_guard<std::mutex> lock(map_mutex_);
  auto it = thread_to_core_map_.find(tid);
  if (it != thread_to_core_map_.end()) {
    return it->second;
  }

  // 自动分配一个核心 ID (兼容旧行为)
  if (next_core_id_ >= cores_.size()) {
    // 如果核心未初始化，默认创建单核环境
    if (cores_.empty()) {
      cores_.emplace_back(0);
    }
    next_core_id_ = 0;
  }

  size_t new_id = next_core_id_;
  thread_to_core_map_[tid] = new_id;
  cores_[new_id].thread_id = tid;
  next_core_id_ = (next_core_id_ + 1) % cores_.size();
  return new_id;
}

auto TestEnvironmentState::GetCurrentCoreEnv() -> CoreEnvironment& {
  auto tid = std::this_thread::get_id();