Package org.testng.internal

Class TestMethodWorker

java.lang.Object

org.testng.internal.TestMethodWorker

All Implemented Interfaces:

java.lang.Comparable<IWorker<ITestNGMethod>>, java.lang.Runnable, IWorker<ITestNGMethod>

Direct Known Subclasses:

SingleTestMethodWorker

public class TestMethodWorker
extends java.lang.Object
implements IWorker<ITestNGMethod>

FIXME: reduce contention when this class is used through parallel invocation due to invocationCount and threadPoolSize by not invoking the @BeforeClass and @AfterClass which are already invoked on the original method.

This class implements Runnable and will invoke the ITestMethod passed in its constructor on its run() method.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	completed
private long	currentThreadId
private ClassMethodMap	m_classMethodMap
private IConfigInvoker	m_configInvoker
private ConfigurationGroupMethods	m_groupMethods
private java.util.List<IClassListener>	m_listeners
private java.util.List<IMethodInstance>	m_methodInstances
private java.util.Map<java.lang.String,java.lang.String>	m_parameters
private ITestContext	m_testContext
private ITestInvoker	m_testInvoker
private java.util.List<ITestResult>	m_testResults
private long	threadIdToRunOn

Constructor Summary

Constructors

Constructor	Description
TestMethodWorker(ITestInvoker testInvoker, IConfigInvoker configInvoker, java.util.List<IMethodInstance> testMethods, java.util.Map<java.lang.String,java.lang.String> parameters, ConfigurationGroupMethods groupMethods, ClassMethodMap classMethodMap, ITestContext testContext, java.util.List<IClassListener> listeners)

Method Summary

Modifier and Type	Method	Description
private boolean	canInvokeBeforeClassMethods()
int	compareTo(IWorker<ITestNGMethod> other)
boolean	completed()
private boolean	doesTaskHavePreRequistes()
long	getCurrentThreadId()
int	getPriority()	The priority of a worker is the priority of the first method it's going to run.
java.util.List<ITestNGMethod>	getTasks()
java.util.List<ITestResult>	getTestResults()
long	getTimeOut()	Retrieves the maximum specified timeout of all ITestNGMethods to be run.
protected int	indexOf(ITestNGMethod tm, ITestNGMethod[] allTestMethods)
protected void	invokeAfterClassMethods(ITestClass testClass, IMethodInstance mi)	Invoke the @AfterClass methods if not done already
protected void	invokeBeforeClassMethods(ITestClass testClass, IMethodInstance mi)	Invoke the @BeforeClass methods if not done already
protected void	invokeTestMethods(ITestNGMethod tm, java.lang.Object instance)
void	run()	Run all the ITestNGMethods passed in through the constructor.
void	setThreadIdToRunOn(long threadIdToRunOn)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.testng.thread.IWorker

getThreadIdToRunOn

Field Detail

m_methodInstances

private java.util.List<IMethodInstance> m_methodInstances

m_parameters

private final java.util.Map<java.lang.String,java.lang.String> m_parameters

m_testResults

private java.util.List<ITestResult> m_testResults

m_groupMethods

private final ConfigurationGroupMethods m_groupMethods

m_classMethodMap

private final ClassMethodMap m_classMethodMap

m_testContext

private final ITestContext m_testContext

m_listeners

private final java.util.List<IClassListener> m_listeners

currentThreadId

private long currentThreadId

threadIdToRunOn

private long threadIdToRunOn

completed

private boolean completed

m_testInvoker

private final ITestInvoker m_testInvoker

m_configInvoker

private final IConfigInvoker m_configInvoker

Constructor Detail

TestMethodWorker

public TestMethodWorker(ITestInvoker testInvoker,
                        IConfigInvoker configInvoker,
                        java.util.List<IMethodInstance> testMethods,
                        java.util.Map<java.lang.String,java.lang.String> parameters,
                        ConfigurationGroupMethods groupMethods,
                        ClassMethodMap classMethodMap,
                        ITestContext testContext,
                        java.util.List<IClassListener> listeners)

Method Detail

getTimeOut

public long getTimeOut()

Retrieves the maximum specified timeout of all ITestNGMethods to be run.

Specified by:

getTimeOut in interface IWorker<ITestNGMethod>

Returns:

the max timeout or 0 if no timeout was specified

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

run

public void run()

Run all the ITestNGMethods passed in through the constructor.

Specified by:

run in interface java.lang.Runnable

See Also:

Runnable.run()

doesTaskHavePreRequistes

private boolean doesTaskHavePreRequistes()

invokeTestMethods

protected void invokeTestMethods(ITestNGMethod tm,
                                 java.lang.Object instance)

canInvokeBeforeClassMethods

private boolean canInvokeBeforeClassMethods()

invokeBeforeClassMethods

protected void invokeBeforeClassMethods(ITestClass testClass,
                                        IMethodInstance mi)

Invoke the @BeforeClass methods if not done already

invokeAfterClassMethods

protected void invokeAfterClassMethods(ITestClass testClass,
                                       IMethodInstance mi)

Invoke the @AfterClass methods if not done already

indexOf

protected int indexOf(ITestNGMethod tm,
                      ITestNGMethod[] allTestMethods)

getTestResults

public java.util.List<ITestResult> getTestResults()

getTasks

public java.util.List<ITestNGMethod> getTasks()

Specified by:

getTasks in interface IWorker<ITestNGMethod>

Returns:

list of tasks this worker is working on.

compareTo

public int compareTo(@Nonnull
                     IWorker<ITestNGMethod> other)

Specified by:

compareTo in interface java.lang.Comparable<IWorker<ITestNGMethod>>

getPriority

public int getPriority()

The priority of a worker is the priority of the first method it's going to run.

Specified by:

getPriority in interface IWorker<ITestNGMethod>

Returns:

the priority of this task.

getCurrentThreadId

public long getCurrentThreadId()

Specified by:

getCurrentThreadId in interface IWorker<ITestNGMethod>

setThreadIdToRunOn

public void setThreadIdToRunOn(long threadIdToRunOn)

Specified by:

setThreadIdToRunOn in interface IWorker<ITestNGMethod>

completed

public boolean completed()

Specified by:

completed in interface IWorker<ITestNGMethod>