Class TestNGFutureTask<T>

java.lang.Object

java.util.concurrent.FutureTask<IWorker<T>>

org.testng.internal.thread.graph.TestNGFutureTask<T>

All Implemented Interfaces:

Comparable<IWorker<T>>, Runnable, Future<IWorker<T>>, RunnableFuture<IWorker<T>>, IWorker<T>

public class TestNGFutureTask<T>
extends FutureTask<IWorker<T>>
implements IWorker<T>

Nested Class Summary

Nested classes/interfaces inherited from interface Future

Future.State

Constructor Summary

Constructors

Constructor	Description
TestNGFutureTask(IWorker<T> worker, BiConsumer<IWorker<T>, Throwable> callback)

Method Summary

Modifier and Type	Method	Description
int	compareTo(IWorker<T> o)
protected void	done()
int	getPriority()
List<T>	getTasks()
long	getTimeOut()
void	run()

Methods inherited from class FutureTask

cancel, exceptionNow, get, get, isCancelled, isDone, resultNow, runAndReset, set, setException, state, toString

Methods inherited from class Object

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

Methods inherited from interface IWorker

completed, getCurrentThreadId, getThreadIdToRunOn, setThreadIdToRunOn

Constructor Details

TestNGFutureTask

public TestNGFutureTask(IWorker<T> worker,
 BiConsumer<IWorker<T>, Throwable> callback)

Method Details

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in interface RunnableFuture<T>

Overrides:

run in class FutureTask<IWorker<T>>

done

protected void done()

Overrides:

done in class FutureTask<IWorker<T>>

getTasks

public List<T> getTasks()

Specified by:

getTasks in interface IWorker<T>

Returns:

list of tasks this worker is working on.

getTimeOut

public long getTimeOut()

Specified by:

getTimeOut in interface IWorker<T>

Returns:

the maximum time allowed for the worker to complete the task.

getPriority

public int getPriority()

Specified by:

getPriority in interface IWorker<T>

Returns:

the priority of this task.

compareTo

public int compareTo(IWorker<T> o)

Specified by:

compareTo in interface Comparable<T>