code: private static void parseThreads(String current, Pipeline pipeline)
              throws ParseException {
          try {
              String threadsStr = current.replaceFirst("threads: ", "").trim();
              int threads = parseInt(threadsStr);
              pipeline.setThreads(threads);
              LOG.info("+-using {} threads ", threads);
          } catch (NumberFormatException e) {
              throw new ParseException("could not parse number of threads from "
                      + current, -1);
          }
      }
docs: Parses # of threads for this pipeline
  
  @return