com.hazelcast.spi

Interface ExecutionService

All Known Subinterfaces:

InternalExecutionService

All Known Implementing Classes:

ExecutionServiceImpl

public interface ExecutionService

A Service responsible for providing access to 'system' executors and customer executors.

It also has functionality for scheduling tasks.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ASYNC_EXECUTOR Name of the async executor.
static String	CLIENT_EXECUTOR Name of the client executor.
static String	IO_EXECUTOR Name of the io executor.
static String	MAP_LOAD_ALL_KEYS_EXECUTOR The name of the executor that loads the MapLoader.loadAllKeys()
static String	MAP_LOADER_EXECUTOR Name of the map-loader executor that loads the MapLoader.loadAll(java.util.Collection).
static String	QUERY_EXECUTOR Name of the query executor.
static String	SCHEDULED_EXECUTOR Name of the scheduled executor.
static String	SYSTEM_EXECUTOR Name of the system executor.

Method Summary

Methods

Modifier and Type	Method and Description
<V> ICompletableFuture<V>	asCompletableFuture(Future<V> future)
void	execute(String name, Runnable command)
ScheduledExecutorService	getDefaultScheduledExecutor()
ManagedExecutorService	getExecutor(String name)
ScheduledExecutorService	getScheduledExecutor(String name)
ManagedExecutorService	register(String name, int poolSize, int queueCapacity, ExecutorType type)
ScheduledFuture<?>	schedule(Runnable command, long delay, TimeUnit unit)
ScheduledFuture<?>	schedule(String name, Runnable command, long delay, TimeUnit unit)
ScheduledFuture<?>	scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
ScheduledFuture<?>	scheduleAtFixedRate(String name, Runnable command, long initialDelay, long period, TimeUnit unit)
ScheduledFuture<?>	scheduleWithFixedDelay(Runnable command, long initialDelay, long period, TimeUnit unit)
ScheduledFuture<?>	scheduleWithFixedDelay(String name, Runnable command, long initialDelay, long period, TimeUnit unit)
void	shutdownExecutor(String name)
<T> Future<T>	submit(String name, Callable<T> task)
Future<?>	submit(String name, Runnable task)

Field Detail

SYSTEM_EXECUTOR

static final String SYSTEM_EXECUTOR

Name of the system executor.

See Also:

Constant Field Values

ASYNC_EXECUTOR

static final String ASYNC_EXECUTOR

Name of the async executor.

See Also:

Constant Field Values

SCHEDULED_EXECUTOR

static final String SCHEDULED_EXECUTOR

Name of the scheduled executor.

See Also:

Constant Field Values

CLIENT_EXECUTOR

static final String CLIENT_EXECUTOR

Name of the client executor.

See Also:

Constant Field Values

QUERY_EXECUTOR

static final String QUERY_EXECUTOR

Name of the query executor.

See Also:

Constant Field Values

IO_EXECUTOR

static final String IO_EXECUTOR

Name of the io executor.

See Also:

Constant Field Values

MAP_LOADER_EXECUTOR

static final String MAP_LOADER_EXECUTOR

Name of the map-loader executor that loads the MapLoader.loadAll(java.util.Collection). This is the executor you want to configure when you want to load more data from the database in parallel.

See Also:

Constant Field Values

MAP_LOAD_ALL_KEYS_EXECUTOR

static final String MAP_LOAD_ALL_KEYS_EXECUTOR

The name of the executor that loads the MapLoader.loadAllKeys()

See Also:

Constant Field Values

Method Detail

register

ManagedExecutorService register(String name,
                              int poolSize,
                              int queueCapacity,
                              ExecutorType type)

getExecutor

ManagedExecutorService getExecutor(String name)

shutdownExecutor

void shutdownExecutor(String name)

execute

void execute(String name,
           Runnable command)

submit

Future<?> submit(String name,
               Runnable task)

submit

<T> Future<T> submit(String name,
                   Callable<T> task)

schedule

ScheduledFuture<?> schedule(Runnable command,
                          long delay,
                          TimeUnit unit)

schedule

ScheduledFuture<?> schedule(String name,
                          Runnable command,
                          long delay,
                          TimeUnit unit)

scheduleAtFixedRate

ScheduledFuture<?> scheduleAtFixedRate(Runnable command,
                                     long initialDelay,
                                     long period,
                                     TimeUnit unit)

scheduleAtFixedRate

ScheduledFuture<?> scheduleAtFixedRate(String name,
                                     Runnable command,
                                     long initialDelay,
                                     long period,
                                     TimeUnit unit)

scheduleWithFixedDelay

ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
                                        long initialDelay,
                                        long period,
                                        TimeUnit unit)

scheduleWithFixedDelay

ScheduledFuture<?> scheduleWithFixedDelay(String name,
                                        Runnable command,
                                        long initialDelay,
                                        long period,
                                        TimeUnit unit)

getDefaultScheduledExecutor

ScheduledExecutorService getDefaultScheduledExecutor()

getScheduledExecutor

ScheduledExecutorService getScheduledExecutor(String name)

asCompletableFuture

<V> ICompletableFuture<V> asCompletableFuture(Future<V> future)