Package org.openspaces.core.executor

Class TaskExecutors

java.lang.Object

org.openspaces.core.executor.TaskExecutors

public class TaskExecutors
extends Object

Author:

kimchy

Constructor Summary

Constructors

Constructor	Description
TaskExecutors()

Method Summary

Modifier and Type	Method	Description
static TaskExecutorService	newExecutorService(GigaSpace gigaSpace)	Constructs a new DefaultTaskExecutorService which is an executor service that can execute tasks on top of the Space.
static <T extends Serializable, R> DistributedTask<T,R>	privilegedTask(DistributedTask<T,R> task)	Constructs a new privileged task wrapping the actual task to execute.
static <T extends Serializable, R> DistributedTask<T,R>	privilegedTask(DistributedTask<T,R> task, AsyncResultFilter<T> filter)	Constructs a new privileged task wrapping the actual task and filter to execute.
static <T extends Serializable> Task<T>	privilegedTask(Task<T> task)	Constructs a new privileged task wrapping the actual task to execute.
static <T extends Serializable> Task<T>	task(Runnable runnable)	Constructs a new runnable task adapter with the runnable to run.
static <T extends Serializable, R> DistributedTask<T,R>	task(Runnable runnable, AsyncResultsReducer<T,R> reducer)	Constructs a new runnable distributed task adapter with a separate reducer.
static <T extends Serializable, R> DistributedTask<T,R>	task(Runnable runnable, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> filter)	Constructs a new runnable distributed task adapter with a separate reducer and filter.
static <T extends Serializable> Task<T>	task(Runnable runnable, T result)	Constructs a new runnable task adapter with the runnable to run.
static <T extends Serializable, R> DistributedTask<T,R>	task(Runnable runnable, T result, AsyncResultsReducer<T,R> reducer)	Constructs a new runnable distributed task adapter with a separate reducer.
static <T extends Serializable, R> DistributedTask<T,R>	task(Runnable runnable, T result, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> filter)	Constructs a new runnable distributed task adapter with a separate reducer and filter.
static <T extends Serializable> Task<T>	task(Callable<T> callable)	Constructs a new callable task adapter with the callable to call.
static <T extends Serializable, R> DistributedTask<T,R>	task(Callable<T> callable, AsyncResultsReducer<T,R> reducer)	Constructs a new callable distributed task adapter with a separate reducer.
static <T extends Serializable, R> DistributedTask<T,R>	task(Callable<T> callable, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> filter)	Constructs a new callable distributed task adapter with a separate reducer and filter.

Methods inherited from class java.lang.Object

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

Constructor Details

TaskExecutors

public TaskExecutors()

Method Details

newExecutorService

public static TaskExecutorService newExecutorService(GigaSpace gigaSpace)

Constructs a new DefaultTaskExecutorService which is an executor service that can execute tasks on top of the Space.

task

public static <T extends Serializable> Task<T> task(Callable<T> callable)

Constructs a new callable task adapter with the callable to call.

task

public static <T extends Serializable,
R>
DistributedTask<T,R> task(Callable<T> callable,
 AsyncResultsReducer<T,R> reducer)

Constructs a new callable distributed task adapter with a separate reducer. The reducer or the callable can optionally implement AsyncResultFilter.

task

public static <T extends Serializable,
R>
DistributedTask<T,R> task(Callable<T> callable,
 AsyncResultsReducer<T,R> reducer,
 AsyncResultFilter<T> filter)

Constructs a new callable distributed task adapter with a separate reducer and filter.

task

public static <T extends Serializable> Task<T> task(Runnable runnable)

Constructs a new runnable task adapter with the runnable to run.

task

public static <T extends Serializable,
R>
DistributedTask<T,R> task(Runnable runnable,
 AsyncResultsReducer<T,R> reducer)

Constructs a new runnable distributed task adapter with a separate reducer. The reducer or the runnable can optionally implement AsyncResultFilter.

task

public static <T extends Serializable,
R>
DistributedTask<T,R> task(Runnable runnable,
 AsyncResultsReducer<T,R> reducer,
 AsyncResultFilter<T> filter)

Constructs a new runnable distributed task adapter with a separate reducer and filter.

task

public static <T extends Serializable,
R>
DistributedTask<T,R> task(Runnable runnable,
 T result,
 AsyncResultsReducer<T,R> reducer)

Constructs a new runnable distributed task adapter with a separate reducer. The reducer or the runnable can optionally implement AsyncResultFilter.

task

public static <T extends Serializable,
R>
DistributedTask<T,R> task(Runnable runnable,
 T result,
 AsyncResultsReducer<T,R> reducer,
 AsyncResultFilter<T> filter)

Constructs a new runnable distributed task adapter with a separate reducer and filter.

task

public static <T extends Serializable> Task<T> task(Runnable runnable,
 T result)

Constructs a new runnable task adapter with the runnable to run. Will return the result after the call to run.

privilegedTask

public static <T extends Serializable> Task<T> privilegedTask(Task<T> task)

Constructs a new privileged task wrapping the actual task to execute.

privilegedTask

public static <T extends Serializable,
R>
DistributedTask<T,R> privilegedTask(DistributedTask<T,R> task)

Constructs a new privileged task wrapping the actual task to execute.

privilegedTask

public static <T extends Serializable,
R>
DistributedTask<T,R> privilegedTask(DistributedTask<T,R> task,
 AsyncResultFilter<T> filter)

Constructs a new privileged task wrapping the actual task and filter to execute.