static void startThreads()

in client/src/main/java/com/google/cloud/solutions/opencensus/client/JettyTestClient.java [202:213]

• 12 lines of code
• 3 McCabe index (conditional complexity)

  static void startThreads(TestOptions testOptions) {
    List<Callable<Void>> callableList = new ArrayList<Callable<Void>>();
    for (int i = 0; i < testOptions.nThreads(); i++) {
      callableList.add(makeCallable(testOptions));
    }
    ExecutorService pool = Executors.newFixedThreadPool(testOptions.nThreads());
    try {
      pool.invokeAll(callableList, 10000, TimeUnit.MILLISECONDS);
    } catch (InterruptedException e) {
      LOGGER.log(Level.WARNING, "Error running threads " + e.getMessage(), e);
    }
  }