У меня есть один тест, который получает данные от поставщика данных. Я бы хотел, чтобы этот тест выполнялся параллельно с другими значениями от поставщика данных.

Я попробовал такой подход, как:

public class IndependentTest
{
@Test(dataProvider = "dp1" ,threadPoolSize=3,invocationCount=1)

public void testMethod(int number)
{
    Long id = Thread.currentThread().getId();
    System.out.println("HELLO :  " + id);
}


@DataProvider(name = "dp1",parallel=true)
public Object[][] dp1() {
  return new Object[][] {
      new Object[] { 1 },
      new Object[] { 2 },
      new Object[] { 3 },
      new Object[] { 4 },
      new Object[] { 5 },
      new Object[] { 6 },
      new Object[] { 7 },
      new Object[] { 8 }

  };
}

}

Вывод, который я получил:

Привет: 10

Привет: 12

ПРИВЕТ: 17

ПРИВЕТ: 11

Привет: 16

ПРИВЕТ: 14

Привет: 13

ПРИВЕТ: 15

Создал 10 потоков, в то время как я указал 5 в размере пула потоков. Не могли бы вы рассказать, что нужно добавить в приведенный выше фрагмент кода для управления размером пула потоков поставщика данных.