com.github.dexecutor.core

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

java.lang.Object

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

Type Parameters:

T - Type of Node/Task ID

R - Type of Node/Task result

All Implemented Interfaces:

ExecutionEngine<T,R>

public final class DefaultExecutionEngine<T extends Comparable<T>,R>
extends Object
implements ExecutionEngine<T,R>

Default Executor, which internally operates on @ExecutorService

Author:

Nadeem Mohammad

Constructor Summary

Constructors

Constructor and Description
DefaultExecutionEngine(ExecutorService executorService) Creates the default instance given @ExecutorService, internally it uses @CompletionService

Method Summary

Methods

Modifier and Type	Method and Description
void	submit(Task<T,R> task)
Future<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

DefaultExecutionEngine

public DefaultExecutionEngine(ExecutorService executorService)

Creates the default instance given @ExecutorService, internally it uses @CompletionService

Parameters:

executorService -

Method Detail

take

public Future<ExecutionResult<T,R>> take()
                                                        throws InterruptedException

Specified by:

take in interface ExecutionEngine<T extends Comparable<T>,R>

Throws:

InterruptedException

submit

public void submit(Task<T,R> task)

Specified by:

submit in interface ExecutionEngine<T extends Comparable<T>,R>

toString

public String toString()

Overrides:

toString in class Object