java - TestNG 并行测试配置

Question

使用 Java 6 上的 TestNG，我想在 Maven 项目中执行以下操作:

1. 启动一个测试方法 (testAbc)，该方法可以使用基于队列的 DataProvider 运行多线程
2. 在 testAbc 中的所有线程完成后启动依赖于 testAbc (testXyz) 的测试

我以为我已经正确配置了它，但事实并非如此。

目前我已将其配置如下:

@Test ( singleThreaded = false )
public class AutomatedTest {

  @Test (
    alwaysRun = true,
    dataProviderClass = UseCaseProvider.class,
    dataProvider = "getUseCasesNoDependencies",
    skipFailedInvocations = false,
    threadPoolSize = 25
  )
  public void testAbc(UseCase useCase) {
    executeUseCase(useCase);
  }

  @Test (
    dependsOnMethods = {"testAbc"},
    dataProviderClass = UseCaseProvider.class,
    dataProvider = "getUseCasesDependencies",
    singleThreaded = true
  )
  public void testXyz(UseCase useCase) {
    executeUseCase(useCase);
  }
}

testAbc 中由 @DataProvider 提供的所有测试都需要很长时间才能运行，但最多可以同时运行 25 个(有好几百个)其中)。 testXyz 中的所有内容都无法并行运行，因为不仅所有情况都依赖于 testAbc，而且处理对这样的线程池并不友好。

我的 Maven 配置设置如下:

<build>
  <plugins>
    <plugin>
      <groupId>org.apache.maven.plugins</groupId>
      <artifactId>maven-surefire-plugin</artifactId>
      <configuration>
        <parallel>methods</parallel>
        <threadCount>25</threadCount>
      </configuration>
    </plugin>
  </plugins>
</build>

当我运行mvn -U test时，我没有看到我的测试实际上是并行运行的。 救命!

$ mvn -version
Apache Maven 2.2.1 (r801777; 2009-08-06 15:16:01-0400)
Java version: 1.6.0_35
Java home: /System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home
Default locale: en_US, platform encoding: MacRoman
OS name: "mac os x" version: "10.7.5" arch: "x86_64" Family: "mac"

Answer 1

添加threadPoolSize怎么样？

@Test ( singleThreaded = false, threadPoolSize = 5 )
public class AutomatedTest {
...

threadPoolSize 属性允许您指定应为此执行分配多少个线程。

编辑

刚刚注意到您错过了inplicationCount。请注意，如果未指定 inplicationCount，则忽略 threadPoolSize。

因此，请尝试保留 @Test 类原样并更新 testAbc

  @Test (
    alwaysRun = true,
    dataProviderClass = UseCaseProvider.class,
    dataProvider = "getUseCasesNoDependencies",
    skipFailedInvocations = false,
    threadPoolSize = 25,
    invocationCount = 25
  )
  public void testAbc(UseCase useCase) {
    executeUseCase(useCase);
  }