com.github.dexecutor.ignite

Class IgniteExecutionEngine<T extends Comparable<T>,R>

java.lang.Object

com.github.dexecutor.ignite.IgniteExecutionEngine<T,R>

Type Parameters:

T -

R -

All Implemented Interfaces:

com.github.dexecutor.core.ExecutionEngine<T,R>

public final class IgniteExecutionEngine<T extends Comparable<T>,R>
extends Object
implements com.github.dexecutor.core.ExecutionEngine<T,R>

Distributed Execution Engine using Ignite

Author:

Nadeem Mohammad

Constructor Summary

Constructors

Constructor and Description
IgniteExecutionEngine(ExecutorService executorService)

Method Summary

Methods

Modifier and Type	Method and Description
void	submit(com.github.dexecutor.core.task.Task<T,R> task)
Future<com.github.dexecutor.core.task.ExecutionResult<T,R>>	take()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

IgniteExecutionEngine

public IgniteExecutionEngine(ExecutorService executorService)

Method Detail

submit

public void submit(com.github.dexecutor.core.task.Task<T,R> task)

Specified by:

submit in interface com.github.dexecutor.core.ExecutionEngine<T extends Comparable<T>,R>

take

public Future<com.github.dexecutor.core.task.ExecutionResult<T,R>> take()
                                                                                       throws InterruptedException

Specified by:

take in interface com.github.dexecutor.core.ExecutionEngine<T extends Comparable<T>,R>

Throws:

InterruptedException

toString

public String toString()

Overrides:

toString in class Object