Package org.testng.internal.thread

Class DefaultThreadPoolExecutorFactory

java.lang.Object

org.testng.internal.thread.DefaultThreadPoolExecutorFactory

All Implemented Interfaces:

IExecutorFactory

public class DefaultThreadPoolExecutorFactory
extends java.lang.Object
implements IExecutorFactory

Constructor Summary

Constructors

Constructor	Description
DefaultThreadPoolExecutorFactory()

Method Summary

Modifier and Type	Method	Description
ITestNGThreadPoolExecutor	newSuiteExecutor(java.lang.String name, IDynamicGraph<ISuite> graph, IThreadWorkerFactory<ISuite> factory, int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.Comparator<ISuite> comparator)
ITestNGThreadPoolExecutor	newTestMethodExecutor(java.lang.String name, IDynamicGraph<ITestNGMethod> graph, IThreadWorkerFactory<ITestNGMethod> factory, int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.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(java.lang.String name,
                                                  IDynamicGraph<ISuite> graph,
                                                  IThreadWorkerFactory<ISuite> factory,
                                                  int corePoolSize,
                                                  int maximumPoolSize,
                                                  long keepAliveTime,
                                                  java.util.concurrent.TimeUnit unit,
                                                  java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                  java.util.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(java.lang.String name,
                                                       IDynamicGraph<ITestNGMethod> graph,
                                                       IThreadWorkerFactory<ITestNGMethod> factory,
                                                       int corePoolSize,
                                                       int maximumPoolSize,
                                                       long keepAliveTime,
                                                       java.util.concurrent.TimeUnit unit,
                                                       java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                       java.util.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.