com.github.dexecutor.core

Class DefaultExecutionEngine<T,R>

java.lang.Object

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

Type Parameters:

T -

R -

All Implemented Interfaces:

ExecutionEngine<T,R>

public final class DefaultExecutionEngine<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
boolean	isShutdown() Returns true if this executor has been shut down.
Future<Node<T,R>>	submit(Callable<Node<T,R>> task) Submits a value-returning task for execution and returns a Future representing the pending results of the task.
Future<Node<T,R>>	take() Retrieves and removes the Future representing the next completed task, waiting if none are yet present.
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

submit

public Future<Node<T,R>> submit(Callable<Node<T,R>> task)

Description copied from interface: ExecutionEngine

Submits a value-returning task for execution and returns a Future representing the pending results of the task. Upon completion, this task may be taken.

Specified by:

submit in interface ExecutionEngine<T,R>

Parameters:

task - the task to submit

Returns:

a Future representing pending completion of the task

take

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

Description copied from interface: ExecutionEngine

Retrieves and removes the Future representing the next completed task, waiting if none are yet present.

Specified by:

take in interface ExecutionEngine<T,R>

Returns:

the Future representing the next completed task

Throws:

InterruptedException - if interrupted while waiting

isShutdown

public boolean isShutdown()

Description copied from interface: ExecutionEngine

Returns true if this executor has been shut down.

Specified by:

isShutdown in interface ExecutionEngine<T,R>

Returns:

true if this executor has been shut down

toString

public String toString()

Overrides:

toString in class Object