com.hazelcast.spi
Interface ExecutionService

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
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
<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)


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.