com.hazelcast.client.spi.impl

Class ClientExecutionServiceImpl

java.lang.Object

com.hazelcast.client.spi.impl.ClientExecutionServiceImpl

All Implemented Interfaces:

ClientExecutionService, MetricsProvider, TaskScheduler, Executor

public final class ClientExecutionServiceImpl
extends Object
implements ClientExecutionService, MetricsProvider

Field Summary

Fields

Modifier and Type	Field and Description
static HazelcastProperty	INTERNAL_EXECUTOR_POOL_SIZE
static long	TERMINATE_TIMEOUT_SECONDS

Constructor Summary

Constructors

Constructor and Description
ClientExecutionServiceImpl(String name, ClassLoader classLoader, HazelcastProperties properties, int poolSize, LoggingService loggingService)

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable command)
ExecutorService	getUserExecutor()
int	getUserExecutorQueueSize()
void	provideMetrics(MetricsRegistry registry)
<V> ScheduledFuture<Future<V>>	schedule(Callable<V> command, long delay, TimeUnit unit) Creates and executes a one-shot action that becomes enabled after the given delay.
ScheduledFuture<?>	schedule(Runnable command, long delay, TimeUnit unit) Creates and executes a one-shot action that becomes enabled after the given delay.
ScheduledFuture<?>	scheduleWithRepetition(Runnable command, long initialDelay, long period, TimeUnit unit) Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period.
void	shutdown()
static void	shutdownExecutor(String name, ExecutorService executor, ILogger logger)

Methods inherited from class java.lang.Object

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

Field Detail

INTERNAL_EXECUTOR_POOL_SIZE

public static final HazelcastProperty INTERNAL_EXECUTOR_POOL_SIZE

TERMINATE_TIMEOUT_SECONDS

public static final long TERMINATE_TIMEOUT_SECONDS

See Also:

Constant Field Values

Constructor Detail

ClientExecutionServiceImpl

public ClientExecutionServiceImpl(String name,
                                  ClassLoader classLoader,
                                  HazelcastProperties properties,
                                  int poolSize,
                                  LoggingService loggingService)

Method Detail

schedule

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

Description copied from interface: TaskScheduler

Creates and executes a one-shot action that becomes enabled after the given delay.

Specified by:

schedule in interface TaskScheduler

Parameters:

command - the task to execute

delay - the time from now to delay execution

unit - the time unit of the delay parameter

Returns:

a ScheduledFuture representing pending completion of the task and whose get() method will return null upon completion

schedule

public <V> ScheduledFuture<Future<V>> schedule(Callable<V> command,
                                               long delay,
                                               TimeUnit unit)

Description copied from interface: TaskScheduler

Creates and executes a one-shot action that becomes enabled after the given delay.

Specified by:

schedule in interface TaskScheduler

Parameters:

command - the task to execute

delay - the time from now to delay execution

unit - the time unit of the delay parameter

Returns:

a ScheduledFuture representing pending completion of the task and whose get() method will return <V> upon completion

scheduleWithRepetition

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

Description copied from interface: TaskScheduler

Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period. Executions will commence after initialDelay then initialDelay+period, then initialDelay + 2 * period, and so on. If any execution of this task takes longer than its period, then subsequent execution will be skipped.

Specified by:

scheduleWithRepetition in interface TaskScheduler

Parameters:

command - the task to execute

initialDelay - the time to delay first execution

period - the period between successive executions

unit - the time unit of the initialDelay and period parameters

Returns:

a ScheduledFuture representing pending completion of the task, and whose get() method will throw an exception upon cancellation

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

getUserExecutor

public ExecutorService getUserExecutor()

Specified by:

getUserExecutor in interface ClientExecutionService

Returns:

executorService that alien (user code) runs on

getUserExecutorQueueSize

public int getUserExecutorQueueSize()

shutdown

public void shutdown()

shutdownExecutor

public static void shutdownExecutor(String name,
                                    ExecutorService executor,
                                    ILogger logger)

provideMetrics

public void provideMetrics(MetricsRegistry registry)

Specified by:

provideMetrics in interface MetricsProvider