org.testng.internal.invokers

Class TestMethodWorker

java.lang.Object

org.testng.internal.invokers.TestMethodWorker

All Implemented Interfaces:

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

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.

Constructor Summary

Constructors

Constructor and 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 and Description
int	compareTo(IWorker<ITestNGMethod> other)
boolean	completed()
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)
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, 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

Constructor Detail

TestMethodWorker

public TestMethodWorker(ITestInvoker testInvoker,
                        IConfigInvoker configInvoker,
                        List<IMethodInstance> testMethods,
                        Map<String,String> parameters,
                        ConfigurationGroupMethods groupMethods,
                        ClassMethodMap classMethodMap,
                        ITestContext testContext,
                        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 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()

invokeTestMethods

protected void invokeTestMethods(ITestNGMethod tm,
                                 Object instance)

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