org.infinispan.distexec
Class DefaultExecutorService

java.lang.Object
  extended by java.util.concurrent.AbstractExecutorService
      extended by org.infinispan.distexec.DefaultExecutorService
All Implemented Interfaces:
Executor, ExecutorService, DistributedExecutorService

public class DefaultExecutorService
extends AbstractExecutorService
implements DistributedExecutorService

Infinispan's implementation of an ExecutorService and DistributedExecutorService. This ExecutorService provides methods to submit tasks for an execution on a cluster of Infinispan nodes.

Note that due to potential task migration to another nodes every Callable, Runnable and/or DistributedCallable submitted must be either Serializable or Externalizable. Also the value returned from a callable must be Serializable or Externalizable. Unfortunately if the value returned is not serializable then a NotSerializableException will be thrown.

Since:
5.0
Author:
Vladimir Blagojevic

Field Summary
protected  AdvancedCache cache
           
protected  CommandsFactory factory
           
protected  InterceptorChain invoker
           
protected  AtomicBoolean isShutdown
           
protected  Marshaller marshaller
           
protected  RpcManager rpc
           
 
Constructor Summary
DefaultExecutorService(Cache masterCacheNode)
          Create a new DefaultExecutorService given a master cache node.
 
Method Summary
 boolean awaitTermination(long timeout, TimeUnit unit)
           
protected
<T> Callable<T>
clone(Callable<T> task)
           
 void execute(Runnable command)
           
protected
<T> void
executeFuture(Address address, org.infinispan.distexec.DefaultExecutorService.DistributedRunnableFuture<T> f)
           
<T> T
invokeAny(Collection<? extends Callable<T>> tasks)
           
<T> T
invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
           
protected
<T> void
invokeLocally(org.infinispan.distexec.DefaultExecutorService.DistributedRunnableFuture<T> future)
           
 boolean isShutdown()
           
 boolean isTerminated()
           
protected
<K> Map<Address,List<K>>
mapKeysToNodes(K... input)
           
protected
<T> RunnableFuture<T>
newTaskFor(Callable<T> callable)
           
protected
<T> RunnableFuture<T>
newTaskFor(Runnable runnable, T value)
           
protected  List<Address> randomClusterMembers(List<Address> members, int numNeeded)
           
protected  Address selectExecutionNode()
           
protected  Address selectExecutionNode(List<Address> candidates)
           
 void shutdown()
           
 List<Runnable> shutdownNow()
           
<T> NotifyingFuture<T>
submit(Callable<T> task)
           
<T,K> Future<T>
submit(Callable<T> task, K... input)
          Submits given Callable task for an execution on a single Infinispan node.
<T> NotifyingFuture<T>
submit(Runnable task, T result)
           
<T> List<Future<T>>
submitEverywhere(Callable<T> task)
          Submits the given Callable task for an execution on all available Infinispan nodes.
<T,K> List<Future<T>>
submitEverywhere(Callable<T> task, K... input)
          Submits the given Callable task for an execution on all available Infinispan nodes using input keys specified by K input.
 
Methods inherited from class java.util.concurrent.AbstractExecutorService
invokeAll, invokeAll, submit
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface java.util.concurrent.ExecutorService
invokeAll, invokeAll, submit
 

Field Detail

isShutdown

protected final AtomicBoolean isShutdown

cache

protected final AdvancedCache cache

rpc

protected final RpcManager rpc

invoker

protected final InterceptorChain invoker

factory

protected final CommandsFactory factory

marshaller

protected final Marshaller marshaller
Constructor Detail

DefaultExecutorService

public DefaultExecutorService(Cache masterCacheNode)
Create a new DefaultExecutorService given a master cache node. All distributed task executions will be initiated from this cache node.

Parameters:
masterCacheNode - cache node initiating map reduce task
Method Detail

submit

public <T> NotifyingFuture<T> submit(Runnable task,
                                     T result)
Specified by:
submit in interface ExecutorService
Overrides:
submit in class AbstractExecutorService

submit

public <T> NotifyingFuture<T> submit(Callable<T> task)
Specified by:
submit in interface ExecutorService
Overrides:
submit in class AbstractExecutorService

shutdown

public void shutdown()
Specified by:
shutdown in interface ExecutorService

shutdownNow

public List<Runnable> shutdownNow()
Specified by:
shutdownNow in interface ExecutorService

isShutdown

public boolean isShutdown()
Specified by:
isShutdown in interface ExecutorService

isTerminated

public boolean isTerminated()
Specified by:
isTerminated in interface ExecutorService

awaitTermination

public boolean awaitTermination(long timeout,
                                TimeUnit unit)
                         throws InterruptedException
Specified by:
awaitTermination in interface ExecutorService
Throws:
InterruptedException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
            throws InterruptedException,
                   ExecutionException
Specified by:
invokeAny in interface ExecutorService
Overrides:
invokeAny in class AbstractExecutorService
Throws:
InterruptedException
ExecutionException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
                       long timeout,
                       TimeUnit unit)
            throws InterruptedException,
                   ExecutionException,
                   TimeoutException
Specified by:
invokeAny in interface ExecutorService
Overrides:
invokeAny in class AbstractExecutorService
Throws:
InterruptedException
ExecutionException
TimeoutException

execute

public void execute(Runnable command)
Specified by:
execute in interface Executor

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Runnable runnable,
                                           T value)
Overrides:
newTaskFor in class AbstractExecutorService

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable)
Overrides:
newTaskFor in class AbstractExecutorService

submit

public <T,K> Future<T> submit(Callable<T> task,
                              K... input)
Description copied from interface: DistributedExecutorService
Submits given Callable task for an execution on a single Infinispan node.

Execution environment will chose an arbitrary node N hosting some or all of the keys specified as input. If all keys are not available locally at node N they will be retrieved from the cluster.

Specified by:
submit in interface DistributedExecutorService
Parameters:
task - a task to execute across Infinispan cluster
input - input keys for this task, effective if and only if task is instance of DistributedCallable
Returns:
a list of Futures, one future per Infinispan cluster node where task was executed

submitEverywhere

public <T> List<Future<T>> submitEverywhere(Callable<T> task)
Description copied from interface: DistributedExecutorService
Submits the given Callable task for an execution on all available Infinispan nodes.

Specified by:
submitEverywhere in interface DistributedExecutorService
Parameters:
task - a task to execute across Infinispan cluster
Returns:
a list of Futures, one future per Infinispan cluster node where task was executed

submitEverywhere

public <T,K> List<Future<T>> submitEverywhere(Callable<T> task,
                                              K... input)
Description copied from interface: DistributedExecutorService
Submits the given Callable task for an execution on all available Infinispan nodes using input keys specified by K input.

Execution environment will chose all nodes in Infinispan cluster where input keys are local, migrate given Callable instance to those nodes, execute it and return result as a list of Futures

Specified by:
submitEverywhere in interface DistributedExecutorService
Parameters:
task - a task to execute across Infinispan cluster
input - input keys for this task, effective if and only if task is instance of DistributedCallable
Returns:
a list of Futures, one future per Infinispan cluster node where task was executed

clone

protected <T> Callable<T> clone(Callable<T> task)

executeFuture

protected <T> void executeFuture(Address address,
                                 org.infinispan.distexec.DefaultExecutorService.DistributedRunnableFuture<T> f)

invokeLocally

protected <T> void invokeLocally(org.infinispan.distexec.DefaultExecutorService.DistributedRunnableFuture<T> future)

mapKeysToNodes

protected <K> Map<Address,List<K>> mapKeysToNodes(K... input)

selectExecutionNode

protected Address selectExecutionNode(List<Address> candidates)

selectExecutionNode

protected Address selectExecutionNode()

randomClusterMembers

protected List<Address> randomClusterMembers(List<Address> members,
                                             int numNeeded)

-->

Copyright © 2011 JBoss, a division of Red Hat. All Rights Reserved.