Method runWorkload

src/main/java/com/oltpbenchmark/DBWorkload.java:781–800

(List<BenchmarkModule> benchList, MonitorInfo monitorInfo)

  }

  private static Results runWorkload(List<BenchmarkModule> benchList, MonitorInfo monitorInfo)
      throws IOException {
    List<Worker<?>> workers = new ArrayList<>();
    List<WorkloadConfiguration> workConfs = new ArrayList<>();
    for (BenchmarkModule bench : benchList) {
      LOG.info("Creating {} virtual terminals...", bench.getWorkloadConfiguration().getTerminals());
      workers.addAll(bench.makeWorkers());

      int num_phases = bench.getWorkloadConfiguration().getNumberOfPhases();
      LOG.info(
          String.format(
              "Launching the %s Benchmark with %s Phase%s...",
              bench.getBenchmarkName().toUpperCase(), num_phases, (num_phases > 1 ? "s" : "")));
      workConfs.add(bench.getWorkloadConfiguration());
    }
    Results r = ThreadBench.runRateLimitedBenchmark(workers, workConfs, monitorInfo);
    LOG.info(SINGLE_LINE);
    LOG.info("Rate limited reqs/s: {}", r);
    return r;
  }

  private static void printUsage(Options options) {
    HelpFormatter hlpfrmt = new HelpFormatter();