com.hazelcast.spi
Interface ExecutionService

public interface ExecutionService

A Service responsible for providing access to 'system' executors and customer executors. It also has functionality for scheduling tasks.

Author:

mdogan 12/14/12

Field Summary

static String	ASYNC_EXECUTOR
static String	CLIENT_EXECUTOR
static String	IO_EXECUTOR
static String	OPERATION_EXECUTOR
static String	QUERY_EXECUTOR
static String	SCHEDULED_EXECUTOR
static String	SYSTEM_EXECUTOR

Method Summary

<V> ICompletableFuture<V>	asCompletableFuture(Future<V> future)
void	execute(String name, Runnable command)
ScheduledExecutorService	getDefaultScheduledExecutor()
com.hazelcast.util.executor.ManagedExecutorService	getExecutor(String name)
ScheduledExecutorService	getScheduledExecutor(String name)
com.hazelcast.util.executor.ManagedExecutorService	register(String name, int poolSize, int queueCapacity, com.hazelcast.util.executor.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

See Also:

Constant Field Values

OPERATION_EXECUTOR

static final String OPERATION_EXECUTOR

See Also:

Constant Field Values

ASYNC_EXECUTOR

static final String ASYNC_EXECUTOR

See Also:

Constant Field Values

SCHEDULED_EXECUTOR

static final String SCHEDULED_EXECUTOR

See Also:

Constant Field Values

CLIENT_EXECUTOR

static final String CLIENT_EXECUTOR

See Also:

Constant Field Values

QUERY_EXECUTOR

static final String QUERY_EXECUTOR

See Also:

Constant Field Values

IO_EXECUTOR

static final String IO_EXECUTOR

See Also:

Constant Field Values

Method Detail

register

com.hazelcast.util.executor.ManagedExecutorService register(String name,
                                                            int poolSize,
                                                            int queueCapacity,
                                                            com.hazelcast.util.executor.ExecutorType type)

getExecutor

com.hazelcast.util.executor.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)