Function run_loop

example/use-execution-queue/example.cpp:58–96

}

void run_loop() {
  size_t times = 0;
  int64_t expect_us = 0;
  while (expect_us < 10000) {
    ++times;
    expect_us = 1000000L * times * FLAGS_concurrency / FLAGS_qps;
  }
  ::std::cerr << "expect_us " << expect_us << " times " << times << ::std::endl;

  void (*run_once)(int64_t);
  if (FLAGS_mode == "babylon") {
    run_once = run_once_babylon;
  } else if (FLAGS_mode == "bthread") {
    run_once = run_once_bthread;
  } else {
    return;
  }

  ::std::vector<::babylon::Future<void>> futures;
  for (size_t i = 0; i < FLAGS_concurrency; ++i) {
    futures.emplace_back(::babylon::BthreadExecutor::instance().execute([&] {
      while (!::brpc::IsAskedToQuit()) {
        auto begin = ::butil::monotonic_time_ns();
        for (size_t j = 0; j < times; ++j) {
          run_once(::butil::monotonic_time_ns());
        }
        auto end = ::butil::monotonic_time_ns();
        auto use_us = (end - begin) / 1000;
        if (use_us < expect_us) {
          ::usleep(expect_us - use_us);
        }
      }
    }));
  }

  for (auto& future : futures) {
    future.get();
  }
}

int main(int argc, char* argv[]) {
  ::gflags::ParseCommandLineFlags(&argc, &argv, true);