@Override
    public void finished() {
      executor.shutdown();
      try {
        String timeoutProp = System.getProperty("junit.parallel.timeout", DEFAULT_TIMEOUT);
        long timeout = Long.parseLong(timeoutProp);
        executor.awaitTermination(timeout, TimeUnit.MINUTES);
      } catch (InterruptedException exc) {
        throw new RuntimeException(exc);
      }
    }
Class to run Parameterized test in parallel.
Source: http://hwellmann.blogspot.hu/2009/12/running-parameterized-junit-tests-in.html
itests/util/src/main/java/org/apache/hive/beeline/Parallelized.java