org.testng.internal.thread

Class DefaultThreadPoolExecutorFactory

java.lang.Object

org.testng.internal.thread.DefaultThreadPoolExecutorFactory

All Implemented Interfaces:

IExecutorFactory

public class DefaultThreadPoolExecutorFactory
extends Object
implements IExecutorFactory

Constructor Summary

Constructors

Constructor and Description
DefaultThreadPoolExecutorFactory()

Method Summary

Modifier and Type	Method and Description
ITestNGThreadPoolExecutor	newSuiteExecutor(String name, IDynamicGraph<ISuite> graph, IThreadWorkerFactory<ISuite> factory, int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Comparator<ISuite> comparator)
ITestNGThreadPoolExecutor	newTestMethodExecutor(String name, IDynamicGraph<ITestNGMethod> graph, IThreadWorkerFactory<ITestNGMethod> factory, int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Comparator<ITestNGMethod> comparator)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultThreadPoolExecutorFactory

public DefaultThreadPoolExecutorFactory()

Method Detail

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.