com.hazelcast.impl

Class ExecutorServiceProxy

java.lang.Object

com.hazelcast.impl.ExecutorServiceProxy

All Implemented Interfaces:

Executor, ExecutorService

public class ExecutorServiceProxy
extends Object
implements ExecutorService

Implements a distributed @link java.util.concurrent.ExecutorService.

Hazelcast to execute your code:

• on a specific cluster member you choose
• on the member owning the key you choose
• on the member Hazelcast will pick
• on all or subset of the cluster members

see @link com.hazelcast.DistributedTask

Note on finalization

The Hazelcast ExecutorService is a facade implementing @link java.util.concurrent.ExecutorService but is not a separate component of the Hazelcast cluster and cannot be finalized. Shutdown the entire cluster instead. Methods invoking finalization have no effect, while methods checking the terminated status return the status of the cluser (isTerminated() return true after an @link com.hazelcast.Hazelcast#shutdown).

Constructor Summary

Constructors

Constructor and Description
ExecutorServiceProxy(Node node, String name)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	awaitTermination(long timeout, TimeUnit unit) Hazelcast ExecutorService cannot be really shut down.
void	execute(Runnable command)
String	getName()
List<Future>	invokeAll(Collection tasks)
List	invokeAll(Collection tasks, long timeout, TimeUnit unit)
Object	invokeAny(Collection tasks)
Object	invokeAny(Collection tasks, long timeout, TimeUnit unit)
boolean	isShutdown() Hazelcast ExecutorService cannot be really shut down.
boolean	isTerminated() Hazelcast ExecutorService cannot be really shut down.
void	shutdown() Hazelcast ExecutorService cannot be really shut down.
List<Runnable>	shutdownNow() Hazelcast ExecutorService cannot be really shut down.
<T> Future<T>	submit(Callable<T> task)
Future<?>	submit(Runnable task)
<T> Future<T>	submit(Runnable task, T result)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorServiceProxy

public ExecutorServiceProxy(Node node,
                    String name)

Method Detail

awaitTermination

public boolean awaitTermination(long timeout,
                       TimeUnit unit)
                         throws InterruptedException

Hazelcast ExecutorService cannot be really shut down. The method return always false immediately.

Specified by:

awaitTermination in interface ExecutorService

Returns:

always false

Throws:

InterruptedException

invokeAll

public List<Future> invokeAll(Collection tasks)
                       throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

public List invokeAll(Collection tasks,
             long timeout,
             TimeUnit unit)
               throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

public Object invokeAny(Collection tasks)
                 throws InterruptedException,
                        ExecutionException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

public Object invokeAny(Collection tasks,
               long timeout,
               TimeUnit unit)
                 throws InterruptedException,
                        ExecutionException,
                        TimeoutException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

isShutdown

public boolean isShutdown()

Hazelcast ExecutorService cannot be really shut down. The method returns the status of the current node.

Specified by:

isShutdown in interface ExecutorService

Returns:

the status of the current node

isTerminated

public boolean isTerminated()

Hazelcast ExecutorService cannot be really shut down. The method returns the status of the current node.

Specified by:

isTerminated in interface ExecutorService

Returns:

the status of the current node

shutdown

public void shutdown()

Hazelcast ExecutorService cannot be really shut down. The method has no effect.

Specified by:

shutdown in interface ExecutorService

shutdownNow

public List<Runnable> shutdownNow()

Hazelcast ExecutorService cannot be really shut down. The method always return an empty list.

Specified by:

shutdownNow in interface ExecutorService

Returns:

an empty list

submit

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

Specified by:

submit in interface ExecutorService

submit

public Future<?> submit(Runnable task)

Specified by:

submit in interface ExecutorService

submit

public <T> Future<T> submit(Runnable task,
                   T result)

Specified by:

submit in interface ExecutorService

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

getName

public String getName()