Class Summary |
AbstractDelegatingDistributedTask<T extends Serializable,R> |
A base class for delegating tasks that are also distributed tasks |
AsyncResultFuture<T> |
A wrapper that implemetns Future that wras an already arrived
AsyncResult . |
AvgReducer<T extends Number,R extends Number> |
A default implementation of a reducer that averages all types T
into a result R . |
AvgTask<T extends Number,R extends Number> |
A sum distrubted task that accepts a Task to delegate
the actual execution to and implements the AvgTask.reduce(java.util.List) operation. |
MaxReducer<T extends Number> |
A default implementation of a reducer that returnt the maximum of T . |
MaxTask<T extends Number> |
A max distrubuted task that accepts a Task to delegate
the actual execution to and implements the MaxTask.reduce(java.util.List) operation. |
MinReducer<T extends Number> |
A default implementation of a reducer that return the minimum of T . |
MinTask<T extends Number> |
A min distrubuted task that accepts a Task to delegate
the actual execution to and implements the MinTask.reduce(java.util.List) operation. |
PrivilegedDistributedTask<T extends Serializable,R> |
A delegating distrubuted task (with an optional filter) that runs under established access control settings. |
PrivilegedTask<T extends Serializable> |
A delegating task that runs under established access control settings. |
SimpleDelegatingDistributedTask<T extends Serializable,R> |
A simple implementation of delegating distributed task that accepts the task to delegate to. |
SimpleDelegatingTask<T extends Serializable> |
A simple implementation of delegating task that accepts the task to delegate to. |
SumReducer<T extends Number,R extends Number> |
A default implementation of a reducer that sums all types T
into a result R . |
SumTask<T extends Number,R extends Number> |
A sum distrubuted task that accepts a Task to delegate
the actual execution to and implements the SumTask.reduce(java.util.List) operation. |
WaitForAllListener<T> |
A listener that can be used to set on several execution and then wait
for all the results (using WaitForAllListener.waitForResult() . |
WaitForAnyListener<T> |
A listener that can be used to set on several execution and then wait
for any of the results (using WaitForAnyListener.waitForResult() . |