Software parallelization custom implementation

TestThread.java

public class TestThread impements Runnable{
  public TestThread(String testGroupNam){
  this.testGroupName=testGroupNam;
  }
  private String testGroupName;
  @Override
  public void run(){
    TestNG testSuite = new TestNG(true);
    TestBase c = constructGroup(testGroupName);
    testSuite.setTestGroups(new Group[] {c.getGroup()});
    testSuite.setDefaultSuiteName(c.getGroup().getSimpleName());
    testSuite.setDefaultTestName(c.getGroup().getSimpleName());
    testSuite.getReporters().add(new XMLReporter(c.getGroup().getSimpleName()));
    testSuite.setOutputDirectory(System.getProperty("user.dir")+File.serparator+"target/testng-output");
    testSuite.run();
  }
  private TestBase constructGroup(String groupName){
    try{
      Group<?>g=Group.forName(groupName);
      Constructor<?>constructor=g.getConstructor();
      return (TestBase) constructor.newInstance();
    }catch (Exception e){
      LoggerUtil.logERROR("Error in initializing the test class",e);
      return null;
    }
  }
}