org.gridgain.grid.kernal.processors.task

Class GridTaskProcessor

java.lang.Object

org.gridgain.grid.kernal.processors.GridProcessorAdapter

org.gridgain.grid.kernal.processors.task.GridTaskProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridTaskProcessor
extends GridProcessorAdapter

This class defines task processor.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridTaskProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
<T,R> GridComputeTaskFuture<R>	execute(Class<? extends GridComputeTask<T,R>> taskCls, T arg)
<T,R> GridComputeTaskFuture<R>	execute(GridComputeTask<T,R> task, T arg)
<T,R> GridComputeTaskFuture<R>	execute(GridComputeTask<T,R> task, T arg, boolean sys)
<T,R> GridComputeTaskFuture<R>	execute(String taskName, T arg)
<T> T	getThreadContext(GridTaskThreadContextKey key) Gets thread-local context value for a given key.
int	getTotalExecutedTasks()
Map<String,GridDeployment>	getUsedDeploymentMap() Gets currently used deployments mapped by task name or aliases.
Collection<GridDeployment>	getUsedDeployments() Gets currently used deployments.
void	onCancelled(GridUuid sesId) Handles user cancellation.
void	onKernalStop(boolean cancel) Callback to notify that kernal is about to stop.
void	printMemoryStats() Prints memory statistics (sizes of internal structures, etc.).
void	processJobExecuteResponse(UUID nodeId, GridJobExecuteResponse msg)
void	resetMetrics() Resets processor metrics.
void	setAttributes(GridTaskSessionImpl ses, Map<?,?> attrs)
void	setThreadContext(GridTaskThreadContextKey key, Object val) Sets the thread-local context value.
void	setThreadContextIfNotNull(GridTaskThreadContextKey key, Object val) Sets the thread-local context value, if it is not null.
void	start() Starts grid component.
void	stop(boolean cancel) Stops grid component.
<R> GridComputeTaskFuture<R>	taskFuture(GridUuid sesId)

Methods inherited from class org.gridgain.grid.kernal.processors.GridProcessorAdapter

addAttributes, assertParameter, collectDiscoveryData, onDiscoveryDataReceived, onKernalStart, toString, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

GridTaskProcessor

public GridTaskProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

start

public void start()

Starts grid component.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

onKernalStop

public void onKernalStop(boolean cancel)

Callback to notify that kernal is about to stop.

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

Parameters:

cancel - Flag indicating whether jobs should be canceled.

stop

public void stop(boolean cancel)

Stops grid component.

Specified by:

stop in interface GridComponent

Overrides:

stop in class GridProcessorAdapter

Parameters:

cancel - If true, then all ongoing tasks or jobs for relevant components need to be cancelled.

setThreadContext

public void setThreadContext(GridTaskThreadContextKey key,
                    Object val)

Sets the thread-local context value.

Parameters:

key - Key.

val - Value.

setThreadContextIfNotNull

public void setThreadContextIfNotNull(GridTaskThreadContextKey key,
                             @Nullable
                             Object val)

Sets the thread-local context value, if it is not null.

Parameters:

key - Key.

val - Value.

getThreadContext

@Nullable
public <T> T getThreadContext(GridTaskThreadContextKey key)

Gets thread-local context value for a given key.

Parameters:

key - Thread-local context key.

Returns:

Thread-local context value associated with given key - or null if value with given key doesn't exist.

getUsedDeployments

public Collection<GridDeployment> getUsedDeployments()

Gets currently used deployments.

Returns:

Currently used deployments.

getUsedDeploymentMap

public Map<String,GridDeployment> getUsedDeploymentMap()

Gets currently used deployments mapped by task name or aliases.

Returns:

Currently used deployments.

execute

public <T,R> GridComputeTaskFuture<R> execute(Class<? extends GridComputeTask<T,R>> taskCls,
                                     @Nullable
                                     T arg)

Type Parameters:

T - Task argument type.

R - Task return value type.

Parameters:

taskCls - Task class.

arg - Optional execution argument.

Returns:

Task future.

execute

public <T,R> GridComputeTaskFuture<R> execute(GridComputeTask<T,R> task,
                                     @Nullable
                                     T arg)

Type Parameters:

T - Task argument type.

R - Task return value type.

Parameters:

task - Actual task.

arg - Optional task argument.

Returns:

Task future.

execute

public <T,R> GridComputeTaskFuture<R> execute(GridComputeTask<T,R> task,
                                     @Nullable
                                     T arg,
                                     boolean sys)

Type Parameters:

T - Task argument type.

R - Task return value type.

Parameters:

task - Actual task.

arg - Optional task argument.

sys - If true, then system pool will be used.

Returns:

Task future.

execute

public <T,R> GridComputeTaskFuture<R> execute(String taskName,
                                     @Nullable
                                     T arg)

Type Parameters:

T - Task argument type.

R - Task return value type.

Parameters:

taskName - Task name.

arg - Optional execution argument.

Returns:

Task future.

taskFuture

@Nullable
public <R> GridComputeTaskFuture<R> taskFuture(GridUuid sesId)

Parameters:

sesId - Task's session id.

Returns:

A GridComputeTaskFuture instance or null if no such task found.

setAttributes

public void setAttributes(GridTaskSessionImpl ses,
                 Map<?,?> attrs)
                   throws GridException

Parameters:

ses - Task session.

attrs - Attributes.

Throws:

GridException - Thrown in case of any errors.

processJobExecuteResponse

public void processJobExecuteResponse(UUID nodeId,
                             GridJobExecuteResponse msg)

Parameters:

nodeId - Node ID.

msg - Execute response message.

onCancelled

public void onCancelled(GridUuid sesId)

Handles user cancellation.

Parameters:

sesId - Session ID.

getTotalExecutedTasks

public int getTotalExecutedTasks()

Returns:

Number of executed tasks.

resetMetrics

public void resetMetrics()

Resets processor metrics.

printMemoryStats

public void printMemoryStats()

Prints memory statistics (sizes of internal structures, etc.). NOTE: this method is for testing and profiling purposes only.

Specified by:

printMemoryStats in interface GridComponent

Overrides:

printMemoryStats in class GridProcessorAdapter