org.gridgain.grid.kernal.processors.job

Class GridJobWorker

java.lang.Object

org.gridgain.grid.util.worker.GridWorker

org.gridgain.grid.kernal.processors.job.GridJobWorker

All Implemented Interfaces:

Runnable, GridTimeoutObject

public class GridJobWorker
extends GridWorker
implements GridTimeoutObject

Job worker.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	body() The implementation should provide the execution body for this runnable.
void	cancel() Cancels this runnable interrupting actual runner.
void	cancel(boolean sys)
long	endTime()
boolean	equals(Object obj)
void	execute() Executes the job.
GridDeployment	getDeployment()
GridComputeJob	getJob() Gets deployed job or null of job could not be deployed.
GridComputeJobContext	getJobContext()
GridUuid	getJobId()
GridJobSessionImpl	getSession()
int	hashCode()
boolean	held()
void	hold() Sets halt flags.
void	onStopping() Callback for whenever grid is stopping.
void	onTimeout() Timeout callback.
GridUuid	timeoutId()
String	toString()

Methods inherited from class org.gridgain.grid.util.worker.GridWorker

cleanup, gridName, isCancelled, isDone, join, name, parent, run, runner

Methods inherited from class java.lang.Object

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

Method Detail

getJob

@Nullable
public GridComputeJob getJob()

Gets deployed job or null of job could not be deployed.

Returns:

Deployed job.

getDeployment

public GridDeployment getDeployment()

Returns:

Deployed task.

getJobId

public GridUuid getJobId()

Returns:

Unique job ID.

getJobContext

public GridComputeJobContext getJobContext()

Returns:

Job context.

getSession

public GridJobSessionImpl getSession()

Returns:

Session.

endTime

public long endTime()

Specified by:

endTime in interface GridTimeoutObject

Returns:

End time.

timeoutId

public GridUuid timeoutId()

Specified by:

timeoutId in interface GridTimeoutObject

Returns:

ID of the object.

onTimeout

public void onTimeout()

Timeout callback.

Specified by:

onTimeout in interface GridTimeoutObject

onStopping

public void onStopping()

Callback for whenever grid is stopping.

held

public boolean held()

Returns:

True if job was halted.

hold

public void hold()

Sets halt flags.

body

protected void body()

The implementation should provide the execution body for this runnable.

Specified by:

body in class GridWorker

execute

public void execute()

Executes the job.

cancel

public void cancel()

Cancels this runnable interrupting actual runner.

Overrides:

cancel in class GridWorker

cancel

public void cancel(boolean sys)

Parameters:

sys - System flag.

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