lepl.core.manager._GeneratorManager

Class _GeneratorManager

MonitorInterface

Configuration

Instance Methods

[hide private]

__init__(self, queue_len)
queue_len is the number of generators that can exist. source code

next_iteration(self, epoch, value, exception, stack)
Store the current epoch.

source code

push(self, generator)
Add a generator if it is not already known, or increment it's ref count.

source code

pop(self, generator)
Decrement a ref's count and update the epoch.

source code

__add(self, generator)
Add a generator, trying to keep the number of active generators to that given in the constructor.

source code

__add_unlimited(self, reference)
Add the new reference and discard any GCed candidates that happen to be on the top of the heap.

source code

__add_limited(self, reference)
Add the new reference, discarding an old entry if possible.

source code

commit(self)
Delete all non-active generators.

source code

Inherited from monitor.ValueMonitor: after_next, after_send, after_throw, before_next, before_send, before_throw, exception, raise_, yield_

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

Properties

[hide private]

Inherited from object: __class__

init(self, queue_len)
(Constructor)

source code

queue_len is the number of generators that can exist. When the number is exceeded the oldest generators are closed, unless currently active (in which case the queue size is extended). If zero then no limit is applied (although generators are still tracked and can be removed using Commit().