org.openspaces.core.executor

Interface Task<T extends Serializable>

All Superinterfaces:

Serializable

All Known Subinterfaces:

DelegatingTask<T>, DistributedTask<T,R>, IMVCCTask<T>

All Known Implementing Classes:

AbstractCommitTwoPhaseTask, AbstractDelegatingDistributedTask, AbstractOnePhaseTask, AbstractPrepareTwoPhaseTask, AvgTask, CallableDistributedTaskAdapter, CallableTaskAdapter, ExecutorRemotingTask, FindNonExpiredSessionsTask, MaxTask, MinTask, MVCCRevertGenerationTask, PrivilegedDistributedTask, PrivilegedTask, RegisterDistributedEventContainerTask, RegisterEventContainerTask, RunnableDistributedTaskAdapter, RunnableTaskAdapter, SimpleDelegatingDistributedTask, SimpleDelegatingTask, SumTask, UnregisterDistributedEventContainerTask, UnregisterEventContainerTask

public interface Task<T extends Serializable>
extends Serializable

A task executed on a space node (processing unit) that returns a result and may throw an exception. Implementors define a single method with no arguments called execute.

Author:

kimchy

Method Summary

Modifier and Type	Method and Description
T	execute() Computes a result, or throws an exception if unable to do so.

Method Detail

execute

T execute()
   throws Exception

Computes a result, or throws an exception if unable to do so.

Returns:

computed result

Throws:

Exception - if unable to compute a result