Class DefaultThreadPoolExecutorFactory

java.lang.Object
org.testng.internal.thread.DefaultThreadPoolExecutorFactory
All Implemented Interfaces:
IExecutorFactory

public class DefaultThreadPoolExecutorFactory extends Object implements IExecutorFactory
  • Constructor Details

    • DefaultThreadPoolExecutorFactory

      public DefaultThreadPoolExecutorFactory()
  • Method Details

    • newSuiteExecutor

      public ITestNGThreadPoolExecutor newSuiteExecutor(String name, IDynamicGraph<ISuite> graph, IThreadWorkerFactory<ISuite> factory, int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Comparator<ISuite> comparator)
      Specified by:
      newSuiteExecutor in interface IExecutorFactory
      Parameters:
      name - - The name to be used as a prefix for all created threads.
      graph - - A IDynamicGraph object that represents the graph of methods and the hierarchy of execution.
      factory - - A IThreadWorkerFactory factory to create threads.
      corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set
      maximumPoolSize - the maximum number of threads to allow in the pool
      keepAliveTime - when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.
      unit - the time unit for the keepAliveTime argument
      workQueue - the queue to use for holding tasks before they are executed. This queue will hold only the Runnable tasks submitted by the execute method.
      comparator - - A Comparator to order nodes internally.
      Returns:
      - A new ITestNGThreadPoolExecutor that is capable of running suites in parallel.
    • newTestMethodExecutor

      public ITestNGThreadPoolExecutor newTestMethodExecutor(String name, IDynamicGraph<ITestNGMethod> graph, IThreadWorkerFactory<ITestNGMethod> factory, int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Comparator<ITestNGMethod> comparator)
      Specified by:
      newTestMethodExecutor in interface IExecutorFactory
      Parameters:
      name - - The name to be used as a prefix for all created threads.
      graph - - A IDynamicGraph object that represents the graph of methods and the hierarchy of execution.
      factory - - A IThreadWorkerFactory factory to create threads.
      corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set
      maximumPoolSize - the maximum number of threads to allow in the pool
      keepAliveTime - when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.
      unit - the time unit for the keepAliveTime argument
      workQueue - the queue to use for holding tasks before they are executed. This queue will hold only the Runnable tasks submitted by the execute method.
      comparator - - A Comparator to order nodes internally.
      Returns:
      - A new ITestNGThreadPoolExecutor that is capable of running test methods in parallel.