Function SleepFor

cpp/src/arrow/testing/gtest_util.cc:761–781

}

void SleepFor(double seconds) {
#ifdef ARROW_ENABLE_THREADING
  std::this_thread::sleep_for(
      std::chrono::nanoseconds(static_cast<int64_t>(seconds * 1e9)));
#else
  using Clock = std::chrono::steady_clock;
  using DurationDouble = std::chrono::duration<double>;

  auto secs_left = DurationDouble(seconds);
  auto start_time = Clock::now();
  auto end_time = start_time + secs_left;
  while (Clock::now() < end_time) {
    bool run_task = arrow::internal::SerialExecutor::RunTasksOnAllExecutors();
    if (!run_task) {
      // all executors are empty, just sleep for the rest of the time
      std::this_thread::sleep_for(end_time - Clock::now());
    }
    // run one task then check time
  }
#endif
}

#ifdef _WIN32
void SleepABit() {