com.hazelcast.client.spi.impl

Class ClientExecutionServiceImpl

java.lang.Object

com.hazelcast.client.spi.impl.ClientExecutionServiceImpl

All Implemented Interfaces:

ClientExecutionService, Executor

public final class ClientExecutionServiceImpl
extends Object
implements ClientExecutionService

Constructor Summary

Constructors

Constructor and Description
ClientExecutionServiceImpl(String name, ThreadGroup threadGroup, ClassLoader classLoader, ClientProperties properties, int poolSize)

Method Summary

Methods

Modifier and Type	Method and Description
void	execute(Runnable command) Execute alien(user code) on execution service
void	executeInternal(Runnable runnable)
ExecutorService	getAsyncExecutor()
ExecutorService	getInternalExecutor()
ScheduledFuture<?>	schedule(Runnable command, long delay, TimeUnit unit) Utilized when given command needs to make a remote call.
ScheduledFuture<?>	scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
ScheduledFuture<?>	scheduleWithFixedDelay(Runnable command, long initialDelay, long period, TimeUnit unit)
void	shutdown()
static void	shutdownExecutor(String name, ExecutorService executor, ILogger logger)
<T> ICompletableFuture<T>	submit(Callable<T> task)
ICompletableFuture<?>	submit(Runnable task)
<T> ICompletableFuture<T>	submitInternal(Runnable runnable)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientExecutionServiceImpl

public ClientExecutionServiceImpl(String name,
                          ThreadGroup threadGroup,
                          ClassLoader classLoader,
                          ClientProperties properties,
                          int poolSize)

Method Detail

executeInternal

public void executeInternal(Runnable runnable)

submitInternal

public <T> ICompletableFuture<T> submitInternal(Runnable runnable)

execute

public void execute(Runnable command)

Description copied from interface: ClientExecutionService

Execute alien(user code) on execution service

Specified by:

execute in interface ClientExecutionService

Specified by:

execute in interface Executor

Parameters:

command - to run

submit

public ICompletableFuture<?> submit(Runnable task)

Specified by:

submit in interface ClientExecutionService

submit

public <T> ICompletableFuture<T> submit(Callable<T> task)

Specified by:

submit in interface ClientExecutionService

schedule

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

Utilized when given command needs to make a remote call. Response of remote call is not handled in runnable itself but rather in execution callback so that executor is not blocked because of a remote operation

Specified by:

schedule in interface ClientExecutionService

Parameters:

command -

delay -

unit -

Returns:

scheduledFuture

scheduleAtFixedRate

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

Specified by:

scheduleAtFixedRate in interface ClientExecutionService

scheduleWithFixedDelay

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

Specified by:

scheduleWithFixedDelay in interface ClientExecutionService

getAsyncExecutor

public ExecutorService getAsyncExecutor()

Specified by:

getAsyncExecutor in interface ClientExecutionService

Returns:

executorService that alien(user code) runs on

shutdown

public void shutdown()

shutdownExecutor

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

getInternalExecutor

public ExecutorService getInternalExecutor()