Package org.apache.ignite.internal.processors.task

Class GridTaskWorker<T,R>

java.lang.Object

org.apache.ignite.internal.util.worker.GridWorker

org.apache.ignite.internal.processors.task.GridTaskWorker<T,R>

Type Parameters:

T - Task argument type.

R - Task return value type.

All Implemented Interfaces:

Runnable, GridTimeoutObject, WorkProgressDispatcher

public class GridTaskWorker<T,R>
extends GridWorker
implements GridTimeoutObject

Grid task worker. Handles full task life cycle.

Field Summary

Fields inherited from class org.apache.ignite.internal.util.worker.GridWorker

isCancelled

Method Summary

Modifier and Type	Method	Description
String	affCacheName()
int	affPartId()
protected void	body()	Maps this task's jobs to nodes and sends them out.
long	endTime()
boolean	equals(Object obj)
GridTaskSessionImpl	getSession()
ComputeTask<T,R>	getTask()
int	hashCode()
boolean	isInternal()
void	onTimeout()	Timeout callback.
void	setTask(ComputeTask<T,R> task)
IgniteUuid	timeoutId()
String	toString()

Methods inherited from class org.apache.ignite.internal.util.worker.GridWorker

blockingSectionBegin, blockingSectionEnd, cancel, cleanup, heartbeatTs, igniteInstanceName, isCancelled, isDone, join, name, onCancel, onCancelledBeforeWorkerScheduled, onIdle, run, runner, updateHeartbeat

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

getSession

public GridTaskSessionImpl getSession()

Returns:

Task session.

getTask

public ComputeTask<T,R> getTask()

Returns:

Grid task.

setTask

public void setTask(ComputeTask<T,R> task)

Parameters:

task - Deployed task.

isInternal

public boolean isInternal()

Returns:

True if task is internal.

timeoutId

public IgniteUuid timeoutId()

Specified by:

timeoutId in interface GridTimeoutObject

Returns:

ID of the object.

onTimeout

public void onTimeout()

Timeout callback.

Specified by:

onTimeout in interface GridTimeoutObject

endTime

public long endTime()

Specified by:

endTime in interface GridTimeoutObject

Returns:

End time.

body

protected void body()

Maps this task's jobs to nodes and sends them out.

Specified by:

body in class GridWorker

affCacheName

public String affCacheName()

Returns:

Affinity cache name for task.

affPartId

public int affPartId()

Returns:

Affinity partition id.

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class GridWorker