protected void testInParallel(StepPhase stepPhase) throws Exception {
    logger.info("Starting the execution of the test runners in parallel " + stepPhase.getName());
    expectedTestDuration = Math.max(expectedTestDuration, size() * 2);
    if (size() > 0) {
      ExecutorService executorService = Executors.newFixedThreadPool(size());
      List<Future<Object>> futureList =
          executorService.invokeAll(this, expectedTestDuration, TimeUnit.MINUTES);
      executorService.shutdown();
      for (Future<Object> future : futureList) {
        future.get();
      }
    }
  }
/**
Executes the tests in parallel.

@throws Exception if an Exception occurs during method execution.
KITE-Framework/src/main/java/org/webrtc/kite/tests/KiteBaseTest.java