com.github.dexecutor.core

Interface ExecutionEngine<T extends Comparable<T>,R>

Type Parameters:

T - Type of Node/Task ID

R - Type of Node/Task result

All Known Implementing Classes:

DefaultExecutionEngine

public interface ExecutionEngine<T extends Comparable<T>,R>

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

Author:

Nadeem Mohammad

Method Summary

Modifier and Type	Method and Description
boolean	isAnyTaskInError()
boolean	isDistributed() Hints dexecutor if the execution engine is distributed or not
ExecutionResult<T,R>	processResult() This method is expected to block, if there are no execution result, otherwise return the result immediately.
void	submit(Task<T,R> task) Submits the task for execution, the method is expected to return immediately.

Method Detail

submit

void submit(Task<T,R> task)

Submits the task for execution, the method is expected to return immediately.

Parameters:

task - to be submitted for execution

processResult

ExecutionResult<T,R> processResult()
                            throws TaskExecutionException

This method is expected to block, if there are no execution result, otherwise return the result immediately.

Returns:

returns the execution result. *

Throws:

TaskExecutionException - if for some reason result can't be processed

isDistributed

boolean isDistributed()

Hints dexecutor if the execution engine is distributed or not

Returns:

true If this execution engine is a distributed false it it is non distributed

isAnyTaskInError

boolean isAnyTaskInError()

Returns:

true if there are any task errors identified till that instance of time false otherwise.