GigaSpaces XAP 9.7.2 API

Uses of Interface
org.openspaces.core.executor.Task

Packages that use Task
org.openspaces.core Top level core package holding main OpenSpaces API for Space (GigaSpace) and Map (GigaMap) and the ability to create it. 
org.openspaces.core.executor   
org.openspaces.core.executor.juc   
org.openspaces.core.executor.support   
org.openspaces.events.support   
org.openspaces.remoting A package including OpenSpaces support for Sync and Async remoting inspired by other Spring remoting integrations. 
 

Uses of Task in org.openspaces.core
 

Methods in org.openspaces.core with parameters of type Task
 ExecutorBuilder<T,R> ExecutorBuilder.add(Task<T> task)
          Adds a task to be executed similarly to GigaSpace.execute(org.openspaces.core.executor.Task).
 ExecutorBuilder<T,R> ExecutorBuilder.add(Task<T> task, AsyncFutureListener<T> listener)
          Adds a task to be executed similarly to GigaSpace.execute(org.openspaces.core.executor.Task).
 ExecutorBuilder<T,R> ExecutorBuilder.add(Task<T> task, Object routing)
          Adds a task to be executed similarly to GigaSpace.execute(org.openspaces.core.executor.Task, Object).
<T extends Serializable>
AsyncFuture<T>
DefaultGigaSpace.execute(Task<T> task)
           
<T extends Serializable>
AsyncFuture<T>
GigaSpace.execute(Task<T> task)
          Executes a task on a specific space node.
<T extends Serializable>
AsyncFuture<T>
DefaultGigaSpace.execute(Task<T> task, AsyncFutureListener<T> listener)
           
<T extends Serializable>
AsyncFuture<T>
GigaSpace.execute(Task<T> task, AsyncFutureListener<T> listener)
          Executes a task on a specific space node.
<T extends Serializable>
AsyncFuture<T>
DefaultGigaSpace.execute(Task<T> task, Object routing)
           
<T extends Serializable>
AsyncFuture<T>
GigaSpace.execute(Task<T> task, Object routing)
          Executes a task on a specific space node.
<T extends Serializable>
AsyncFuture<T>
DefaultGigaSpace.execute(Task<T> task, Object routing, AsyncFutureListener<T> listener)
           
<T extends Serializable>
AsyncFuture<T>
GigaSpace.execute(Task<T> task, Object routing, AsyncFutureListener<T> listener)
          Executes a task on a specific space node.
 

Uses of Task in org.openspaces.core.executor
 

Subinterfaces of Task in org.openspaces.core.executor
 interface DistributedTask<T extends Serializable,R>
          A distributed task is a Task that is executed on several space nodes, requiring to AsyncResultsReducer.reduce(java.util.List) the list of AsyncResults.
 

Methods in org.openspaces.core.executor that return Task
static
<T extends Serializable>
Task<T>
TaskExecutors.privilegedTask(Task<T> task)
          Constructs a new privileged task wrapping the actual task to execute.
static
<T extends Serializable>
Task<T>
TaskExecutors.task(Callable<T> callable)
          Constructs a new callable task adapter with the callable to call.
static
<T extends Serializable>
Task<T>
TaskExecutors.task(Runnable runnable)
          Constructs a new runnable task adapter with the runnable to run.
static
<T extends Serializable>
Task<T>
TaskExecutors.task(Runnable runnable, T result)
          Constructs a new runnable task adapter with the runnable to run.
 

Methods in org.openspaces.core.executor with parameters of type Task
static
<T extends Serializable>
Task<T>
TaskExecutors.privilegedTask(Task<T> task)
          Constructs a new privileged task wrapping the actual task to execute.
 

Uses of Task in org.openspaces.core.executor.juc
 

Classes in org.openspaces.core.executor.juc that implement Task
 class CallableDistributedTaskAdapter<T extends Serializable,R>
          An adapter allowing to execute a Callable in a distributed fashion.
 class CallableTaskAdapter<T extends Serializable>
          An adapter allowing to execute a Callable using Space task executors.
 class RunnableDistributedTaskAdapter<T extends Serializable,R>
          An adapter allowing to execute a Runnable in a distributed fashion.
 class RunnableTaskAdapter<T extends Serializable>
          An adapter allowing to execute a Runnable using Space task executors.
 

Uses of Task in org.openspaces.core.executor.support
 

Subinterfaces of Task in org.openspaces.core.executor.support
 interface DelegatingTask<T extends Serializable>
          A delegating task is a task that holds another task that will be executed.
 

Classes in org.openspaces.core.executor.support that implement Task
 class AbstractDelegatingDistributedTask<T extends Serializable,R>
          A base class for delegating tasks that are also distributed tasks
 class 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.
 class 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.
 class 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.
 class PrivilegedDistributedTask<T extends Serializable,R>
          A delegating distrubuted task (with an optional filter) that runs under established access control settings.
 class PrivilegedTask<T extends Serializable>
          A delegating task that runs under established access control settings.
 class SimpleDelegatingDistributedTask<T extends Serializable,R>
          A simple implementation of delegating distributed task that accepts the task to delegate to.
 class SimpleDelegatingTask<T extends Serializable>
          A simple implementation of delegating task that accepts the task to delegate to.
 class 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.
 

Methods in org.openspaces.core.executor.support that return Task
 Task<T> SimpleDelegatingTask.getDelegatedTask()
          Returns the delegated task the task will execute to.
 Task<T> DelegatingTask.getDelegatedTask()
          Returns the delegating task that will be executed.
 

Constructors in org.openspaces.core.executor.support with parameters of type Task
AbstractDelegatingDistributedTask(Task<T> task)
           
AbstractDelegatingDistributedTask(Task<T> task, AsyncResultFilter<T> filter)
           
AvgTask(Class<R> reduceType, Task<T> task)
          Constructs a new sum distributed task that delegates the actual execution to th provided task.
AvgTask(Class<R> reduceType, Task<T> task, AsyncResultFilter<T> filter)
          Constructs a new sum distributed task that delegates the actual execution to th provided task.
MaxTask(Class<T> reduceType, Task<T> task)
          Constructs a new sum distributed task that delegates the actual execution to th provided task.
MaxTask(Class<T> reduceType, Task<T> task, AsyncResultFilter<T> filter)
          Constructs a new sum distributed task that delegates the actual execution to th provided task.
MinTask(Class<T> reduceType, Task<T> task)
          Constructs a new sum distributed task that delegates the actual execution to th provided task.
MinTask(Class<T> reduceType, Task<T> task, AsyncResultFilter<T> filter)
          Constructs a new sum distributed task that delegates the actual execution to th provided task.
PrivilegedTask(Task<T> task)
          Constructs a new privileged task wrapping the actual task to execute.
SimpleDelegatingTask(Task<T> task)
          Constructs a new simple delegating task with the task to delegate to.
SumTask(Class<R> reduceType, Task<T> task)
          Constructs a new sum distributed task that delegates the actual execution to th provided task.
SumTask(Class<R> reduceType, Task<T> task, AsyncResultFilter<T> filter)
          Constructs a new sum distributed task that delegates the actual execution to th provided task.
 

Uses of Task in org.openspaces.events.support
 

Classes in org.openspaces.events.support that implement Task
 class RegisterDistributedEventContainerTask
          A task that registers a dynamically added event container in a distributed manner.
 class RegisterEventContainerTask
          A task that registers a dynamically added event container (using Polling or Notify.
 class UnregisterDistributedEventContainerTask
          A task that unregisters (stops and disposes it) a dynamically added event container in a distributed manner.
 class UnregisterEventContainerTask
          A task that unregisters (stops and disposes it) a dynamically added event container (using Polling or Notify.
 

Uses of Task in org.openspaces.remoting
 

Classes in org.openspaces.remoting that implement Task
 class ExecutorRemotingTask<T extends Serializable>
          A Task that can be used to simulate remote invocation with SpaceRemotingServiceExporter.
 


GigaSpaces XAP 9.7.2 API

Copyright © GigaSpaces.