package test.thread;

import org.testng.Assert;
import org.testng.TestNG;
import org.testng.annotations.Test;

import test.SimpleBaseTest;

public class DataProviderThreadPoolSizeTest extends SimpleBaseTest {

  @Test
  public void shouldUseDefaultDataProviderThreadCount() {
    TestNG tng = create(DataProviderThreadPoolSizeSampleTest.class);
    tng.setGroups("parallel");
    tng.run();
    Assert.assertEquals(DataProviderThreadPoolSizeSampleTest.getThreadCount(), 10);
  }

  @Test
  public void shouldNotUseThreadsIfNotUsingParallel() {
    TestNG tng = create(DataProviderThreadPoolSizeSampleTest.class);
    tng.setGroups("sequential");
    tng.run();
    Assert.assertEquals(DataProviderThreadPoolSizeSampleTest.getThreadCount(), 1);
  }

  @Test
  public void shouldUseSpecifiedDataProviderThreadCount() {
    TestNG tng = create(DataProviderThreadPoolSizeSampleTest.class);
    tng.setGroups("parallel");
    tng.setDataProviderThreadCount(3);
    tng.run();
    Assert.assertEquals(DataProviderThreadPoolSizeSampleTest.getThreadCount(), 3);
  }
}