Package 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	Description
DefaultThreadPoolExecutorFactory()

Method Summary

Modifier and Type	Method	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 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.