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

Packages that use Task

Package	Description
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.internal
org.openspaces.core.executor.juc
org.openspaces.core.executor.support
org.openspaces.events.support
org.openspaces.extensions
org.openspaces.pu.container.jee.jetty.session
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

Modifier and Type	Method and Description
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

Modifier and Type	Interface and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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.internal

Methods in org.openspaces.core.executor.internal that return Task

Modifier and Type	Method and Description
Task<T>	InternalSpaceTaskWrapper.getTask()

Constructors in org.openspaces.core.executor.internal with parameters of type Task

Constructor and Description
InternalSpaceTaskWrapper(Task<T> task, Object routing)

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

Classes in org.openspaces.core.executor.juc that implement Task

Modifier and Type	Class and Description
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

Modifier and Type	Interface and Description
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

Modifier and Type	Class and Description
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

Modifier and Type	Method and Description
Task<T>	DelegatingTask.getDelegatedTask() Returns the delegating task that will be executed.
Task<T>	SimpleDelegatingTask.getDelegatedTask() Returns the delegated task the task will execute to.

Constructors in org.openspaces.core.executor.support with parameters of type Task

Constructor and Description
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

Modifier and Type	Class and Description
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.extensions

Methods in org.openspaces.extensions with parameters of type Task

Modifier and Type	Method and Description
static <T extends Serializable> CompletableFuture<T>	AsyncExtension.execute(GigaSpace gigaSpace, Task<T> task)
static <T extends Serializable> CompletableFuture<T>	AsyncExtension.execute(GigaSpace gigaSpace, Task<T> task, Object... routing)
static <T extends Serializable> CompletableFuture<T>	AsyncExtension.execute(GigaSpace gigaSpace, Task<T> task, Object routing)

Uses of Task in org.openspaces.pu.container.jee.jetty.session

Classes in org.openspaces.pu.container.jee.jetty.session that implement Task

Modifier and Type	Class and Description
class	FindNonExpiredSessionsTask

Uses of Task in org.openspaces.remoting

Classes in org.openspaces.remoting that implement Task

Modifier and Type	Class and Description
class	ExecutorRemotingTask<T extends Serializable> A Task that can be used to simulate remote invocation with SpaceRemotingServiceExporter.