Package mdp :: Package parallel :: Class ExecuteResultContainer

Class ExecuteResultContainer

Default result container with automatic restoring of the result order.

This result container should be used together with BiFlowExecuteCallable.
Both the execute result (x and possibly msg) and the forked BiFlowNode
are stored.

Instance Methods

[hide private]

__init__(self)
Initialize attributes.

add_result(self, result, task_index)
Remove the forked BiFlowNode from the result and join it.

get_results(self)
Return the ordered results.

Inherited from unreachable.newobject: __long__, __native__, __nonzero__, __unicode__, next

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

init(self)
(Constructor)

Initialize attributes.

Overrides: object.__init__

add_result(self, result, task_index)

Remove the forked BiFlowNode from the result and join it.

Overrides: ResultContainer.add_result

get_results(self)

Return the ordered results.

The joined BiFlowNode is returned in the first result list entry,
for the following result entries BiFlowNode is set to None.
This reduces memory consumption while staying transparent for the
ParallelBiFlow.

Overrides: ResultContainer.get_results

Class ExecuteResultContainer

__init__(self) (Constructor)

add_result(self, result, task_index)

get_results(self)

init(self)
(Constructor)