Package org.apache.ignite.internal.executor

Class GridExecutorService

java.lang.Object

org.apache.ignite.internal.executor.GridExecutorService

All Implemented Interfaces:

Externalizable, Serializable, Executor, ExecutorService

public class GridExecutorService
extends Object
implements ExecutorService, Externalizable

An ExecutorService that executes each submitted task in grid through Ignite instance, normally configured using Ignite.executorService() method. GridExecutorService delegates commands execution to already started Ignite instance. Every submitted task will be serialized and transferred to any node in grid.

All submitted tasks must implement Serializable interface.

Note, that GridExecutorService implements ExecutorService from JDK 1.5. If you have problems with compilation for JDK 1.6 and above you need to apply some changes (see http://bugs.sun.com/bugdatabase/view_bug.do?bug_id=6267833)

Change signature for methods invokeAll(Collection), invokeAll(Collection, long, TimeUnit), invokeAny(Collection), invokeAny(Collection, long, TimeUnit) to

 public class GridExecutorService implements ExecutorService {
 ...
     public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException {
         ...
     }

     public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
         throws InterruptedException {
         ...
     }

     public <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException {
         ...
     }

     public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
         throws InterruptedException, ExecutionException, TimeoutException {
     }
     ...
 }
 

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
GridExecutorService()	No-arg constructor is required by externalization.
GridExecutorService(ClusterGroupAdapter prj, GridKernalContext ctx)	Creates executor service.

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit unit)
void	execute(Runnable cmd)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
boolean	isShutdown()
boolean	isTerminated()
void	readExternal(ObjectInput in)
protected Object	readResolve()	Reconstructs object on unmarshalling.
void	shutdown()
List<Runnable>	shutdownNow()
Future<?>	submit(Runnable task)
<T> Future<T>	submit(Runnable task, T res)
<T> Future<T>	submit(Callable<T> task)
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

GridExecutorService

public GridExecutorService()

No-arg constructor is required by externalization.

GridExecutorService

public GridExecutorService(ClusterGroupAdapter prj,
                           GridKernalContext ctx)

Creates executor service.

Parameters:

prj - Projection.

ctx - Grid logger.

Method Detail

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

readResolve

protected Object readResolve()
                      throws ObjectStreamException

Reconstructs object on unmarshalling.

Returns:

Reconstructed object.

Throws:

ObjectStreamException - Thrown in case of unmarshalling error.

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

submit

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

Specified by:

submit in interface ExecutorService

submit

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

Specified by:

submit in interface ExecutorService

submit

public Future<?> submit(Runnable task)

Specified by:

submit in interface ExecutorService

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
                              throws InterruptedException

Note, for compilation with JDK 1.6 necessary to change method signature (note the <? extends T> clause).

     ...
     public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException {
         // Method body.
     }
     ...
 

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                                     long timeout,
                                     TimeUnit unit)
                              throws InterruptedException

Note, for compilation with JDK 1.6 necessary to change method signature (note the <? extends T> clause).

     public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
         throws InterruptedException {
         ...
     }
 

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
                throws InterruptedException,
                       ExecutionException

Note, for compilation with JDK 1.6 necessary to change method signature (note the <? extends T> clause).

     ...
     public <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException {
         // Method body.
     }
     ...
 

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
                       long timeout,
                       TimeUnit unit)
                throws InterruptedException,
                       ExecutionException,
                       TimeoutException

Note, for compilation with JDK 1.6 necessary to change method signature (note the <? extends T> clause).

     ...
     public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
         throws InterruptedException, ExecutionException, TimeoutException {
     }
     ...
 

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

execute

public void execute(Runnable cmd)

Specified by:

execute in interface Executor