com.hazelcast.client.spi.impl
Class ClientExecutionServiceImpl

java.lang.Object
  com.hazelcast.client.spi.impl.ClientExecutionServiceImpl

All Implemented Interfaces:

ClientExecutionService

public final class ClientExecutionServiceImpl
extends Object
implements ClientExecutionService

Constructor Summary

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

Method Summary

void	execute(Runnable command)
ExecutorService	getAsyncExecutor()
ScheduledFuture<?>	schedule(Runnable command, long delay, TimeUnit unit)
ScheduledFuture<?>	scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
ScheduledFuture<?>	scheduleWithFixedDelay(Runnable command, long initialDelay, long period, TimeUnit unit)
void	shutdown()
<T> ICompletableFuture<T>	submit(Callable<T> task)
ICompletableFuture<?>	submit(Runnable task)
<T> ICompletableFuture<T>	submitInternal(Callable<T> command)

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,
                                  int poolSize)

Method Detail

submitInternal

public <T> ICompletableFuture<T> submitInternal(Callable<T> command)

execute

public void execute(Runnable command)

Specified by:

execute in interface ClientExecutionService

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)

Specified by:

schedule in interface ClientExecutionService

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

shutdown

public void shutdown()