Package Biskit :: Package PVM :: Module Status :: Class Status

[frames] | no frames]

Class Status

source code

Keep track of objects that are processed by JobMaster.

Thread-savety:

next_chunk() is synchronized.
deactivate() must be synchronized to the same Status.lock
activate() is not any longer supposed to be called from outside.

Instance Methods

[hide private]

__init__(self, objects, redistribute=1)

__activate(self, item)
not thread-save, synchronize on self.lock!

deactivate(self, item)
mark item as processed.

[object] not_done(self)
Not yet finished items.

[object] not_started(self)
Returns list of not yet started items

[object] activ(self)
Returns list of currently active (started) items

1|0 done(self)
Returns 1 if all items have been processed and finished

([object], int) OR None next_chunk(self, nmax)
Get next chunk of at most nmax items that need to be processed.

__str__(self)

__repr__(self)

Method Details

[hide private]

init(self, objects, redistribute=1)
(Constructor)

source code

Parameters:

objects (any) - e.g. job IDs
redistribute (1|0) - send out started but not yet finished jobs to idle slaves (to not wait for slow slaves) (default: 1)

__activate(self, item)

source code

not thread-save, synchronize on self.lock!

deactivate(self, item)

source code

mark item as processed. not thread-save, synchronize on self.lock!

not_done(self)

source code

Not yet finished items. The not-yet-started come first, then come the active items ordered by how often they have already been distributed.

Returns: [object]: list of not yet finished items (started or not)

not_started(self)

source code

Returns: [object]: list of not yet started items

activ(self)

source code

Returns: [object]: list of currently active (started) items

done(self)

source code

Returns: 1|0: 1 if all items have been processed and finished

next_chunk(self, nmax)

source code

Get next chunk of at most nmax items that need to be processed. Thread-save.

Parameters:

nmax (int) - size of chunk

Returns: ([object], int) OR None: chunk of items to be processed, number of unproc OR None if all items have been processed

str(self)
(Informal representation operator)

source code

repr(self)
(Representation operator)

source code

Class Status

__init__(self, objects, redistribute=1) (Constructor)

__activate(self, item)

deactivate(self, item)

not_done(self)

not_started(self)

activ(self)

done(self)

next_chunk(self, nmax)

__str__(self) (Informal representation operator)

__repr__(self) (Representation operator)

init(self, objects, redistribute=1)
(Constructor)

str(self)
(Informal representation operator)

repr(self)
(Representation operator)