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
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.
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

processResult

public ExecutionResult<T,R> processResult()

Description copied from interface: ExecutionEngine

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

Specified by:

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

Returns:

@ExecutionResult returns the execution result. *

submit

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

Description copied from interface: ExecutionEngine

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

Specified by:

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

isDistributed

public boolean isDistributed()

Description copied from interface: ExecutionEngine

Hints dexecutor if the execution engine is distributed or not

Specified by:

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

Returns:

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

isAnyTaskInError

public boolean isAnyTaskInError()

Specified by:

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

Returns:

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

toString

public String toString()

Overrides:

toString in class Object