Function main

be/src/benchmarks/thread-create-benchmark.cc:126–214

}

int main(int argc, char **argv) {
  google::InitGoogleLogging(argv[0]);
  CpuInfo::Init();
  impala::InitThreading();

  cout << "-----------------Benchmark 1: Single-threaded thread creation" << endl;

  // Measure how long it takes to start up a bunch of threads
  StopWatch total_time;
  total_time.Start();

  TimeParallelExecutors(1, 1);
  TimeParallelExecutors(1, 5);
  TimeParallelExecutors(1, 50);
  TimeParallelExecutors(1, 500);
  TimeParallelExecutors(1, 5000);

  total_time.Stop();

  cout << "Total time (Native): "
       << PrettyPrinter::Print(total_time.ElapsedTime(), TUnit::CPU_TICKS)
       << endl << endl;

  // Measure how long it takes to start up a bunch of threads
  StopWatch total_time_imp;
  total_time_imp.Start();

  TimeParallelExecutors(1, 1, false);
  TimeParallelExecutors(1, 5, false);
  TimeParallelExecutors(1, 50, false);
  TimeParallelExecutors(1, 500, false);
  TimeParallelExecutors(1, 5000, false);

  total_time_imp.Stop();

  cout << "Total time (IMPALA): "
       << PrettyPrinter::Print(total_time_imp.ElapsedTime(), TUnit::CPU_TICKS)
       << endl << endl;

  int64_t difference = total_time_imp.ElapsedTime() - total_time.ElapsedTime();
  cout << "Impala thread overhead: "
       << PrettyPrinter::Print(difference, TUnit::CPU_TICKS)
       << ", which is " << (difference * 100.0 / total_time.ElapsedTime())
       << "%" << endl << endl;


  cout << "-----------------Benchmark 2: Multi-threaded thread creation" << endl;

  // Measure how long it takes to start up a bunch of threads
  StopWatch total_time_parallel_native;
  total_time_parallel_native.Start();

  TimeParallelExecutors(20, 1);
  TimeParallelExecutors(20, 5);
  TimeParallelExecutors(20, 50);
  TimeParallelExecutors(20, 500);

  total_time_parallel_native.Stop();