test/src/test/tmp/C.java

package test.tmp;

import org.testng.annotations.DataProvider;
import org.testng.annotations.Test;

import java.util.ArrayList;

public class C extends B {
  @Test(threadPoolSize = 10, dataProvider = "data") 
  public void testMethod(Integer val) {
    System.out.print(Thread.currentThread().getId() + " ");
  }

  @DataProvider(name = "data", parallel = true) 
  public Object[][] data() { 
    final ArrayList<Integer[]> resa = new ArrayList<Integer[]>(); 
    for(int i = 0; i < 1000; i ++) { 
      resa.add(new Integer[]{i}); 
    } 
    return resa.toArray(new Object[1][resa.size()]); 
  }
}