Package org.testng.internal.thread
Class DefaultThreadPoolExecutorFactory
java.lang.Object
org.testng.internal.thread.DefaultThreadPoolExecutorFactory
- All Implemented Interfaces:
IExecutorFactory
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionnewSuiteExecutor
(String name, IDynamicGraph<ISuite> graph, IThreadWorkerFactory<ISuite> factory, int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Comparator<ISuite> comparator) newTestMethodExecutor
(String name, IDynamicGraph<ITestNGMethod> graph, IThreadWorkerFactory<ITestNGMethod> factory, int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Comparator<ITestNGMethod> comparator)
-
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 interfaceIExecutorFactory
- Parameters:
name
- - The name to be used as a prefix for all created threads.graph
- - AIDynamicGraph
object that represents the graph of methods and the hierarchy of execution.factory
- - AIThreadWorkerFactory
factory to create threads.corePoolSize
- the number of threads to keep in the pool, even if they are idle, unlessallowCoreThreadTimeOut
is setmaximumPoolSize
- the maximum number of threads to allow in the poolkeepAliveTime
- 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 thekeepAliveTime
argumentworkQueue
- the queue to use for holding tasks before they are executed. This queue will hold only theRunnable
tasks submitted by theexecute
method.comparator
- - AComparator
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 interfaceIExecutorFactory
- Parameters:
name
- - The name to be used as a prefix for all created threads.graph
- - AIDynamicGraph
object that represents the graph of methods and the hierarchy of execution.factory
- - AIThreadWorkerFactory
factory to create threads.corePoolSize
- the number of threads to keep in the pool, even if they are idle, unlessallowCoreThreadTimeOut
is setmaximumPoolSize
- the maximum number of threads to allow in the poolkeepAliveTime
- 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 thekeepAliveTime
argumentworkQueue
- the queue to use for holding tasks before they are executed. This queue will hold only theRunnable
tasks submitted by theexecute
method.comparator
- - AComparator
to order nodes internally.- Returns:
- - A new
ITestNGThreadPoolExecutor
that is capable of running test methods in parallel.
-