com.github.dexecutor.core

Interface ExecutionEngine<T,R>

Type Parameters:

T -

R -

All Known Implementing Classes:

DefaultExecutionEngine

public interface ExecutionEngine<T,R>

An Executor is the main execution engine, where in all the tasks are executed

Author:

Nadeem Mohammad

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.

Method Detail

submit

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. Upon completion, this task may be taken.

Parameters:

task - the task to submit

Returns:

a Future representing pending completion of the task

Throws:

RejectedExecutionException - if the task cannot be scheduled for execution

NullPointerException - if the task is null

take

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

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

Returns:

the Future representing the next completed task

Throws:

InterruptedException - if interrupted while waiting

isShutdown

boolean isShutdown()

Returns true if this executor has been shut down.

Returns:

true if this executor has been shut down