Package org.testng.internal.invokers

Class TestMethodWorker

java.lang.Object

org.testng.internal.invokers.TestMethodWorker

All Implemented Interfaces:

Comparable<IWorker<ITestNGMethod>>, Runnable, IWorker<ITestNGMethod>

Direct Known Subclasses:

SingleTestMethodWorker

public class TestMethodWorker
extends 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 final ClassMethodMap	m_classMethodMap
private final IConfigInvoker	m_configInvoker
private final ConfigurationGroupMethods	m_groupMethods
private final List<IClassListener>	m_listeners
private final List<IMethodInstance>	m_methodInstances
private final Map<String,String>	m_parameters
private final ITestContext	m_testContext
private final ITestInvoker	m_testInvoker
private final List<ITestResult>	m_testResults
private long	threadIdToRunOn

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
private boolean	canInvokeBeforeClassMethods()
int	compareTo(IWorker<ITestNGMethod> other)
boolean	completed()
private boolean	doesTaskHavePreRequisites()
long	getCurrentThreadId()
int	getPriority()	The priority of a worker is the priority of the first method it's going to run.
List<ITestNGMethod>	getTasks()
List<ITestResult>	getTestResults()
long	getTimeOut()	Retrieves the maximum specified timeout of all ITestNGMethods to be run.
protected int	indexOf(ITestNGMethod tm, ITestNGMethod[] allTestMethods)
private void	invokeAfterClassConfigurations(ITestClass testClass, List<Object> invokeInstances)
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
private void	invokeListenersOnAfterClass(ITestClass testClass, List<IClassListener> listeners)
protected void	invokeTestMethods(ITestNGMethod tm, Object instance)
void	run()	Run all the ITestNGMethods passed in through the constructor.
void	setThreadIdToRunOn(long threadIdToRunOn)
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 Details

m_methodInstances

private final List<IMethodInstance> m_methodInstances

m_parameters

private final Map<String,String> m_parameters

m_testResults

private final 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 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 Details

TestMethodWorker

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

Method Details

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 String toString()

Overrides:

toString in class Object

run

public void run()

Run all the ITestNGMethods passed in through the constructor.

Specified by:

run in interface Runnable

See Also:

• Runnable.run()

doesTaskHavePreRequisites

private boolean doesTaskHavePreRequisites()

invokeTestMethods

protected void invokeTestMethods(ITestNGMethod tm,
 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

invokeAfterClassConfigurations

private void invokeAfterClassConfigurations(ITestClass testClass,
 List<Object> invokeInstances)

invokeListenersOnAfterClass

private void invokeListenersOnAfterClass(ITestClass testClass,
 List<IClassListener> listeners)

indexOf

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

getTestResults

public List<ITestResult> getTestResults()

getTasks

public 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 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>