Module: vemomoto_core.concurrent.nicepar

Created on 27.04.2016

@author: Samuel

Classes:

CircularParallelCounter([size, lock])
Counter([size, interval])
DummyObj(parent)
DummyVar(value)
Lockable([lock])
Locked(parent)	Context manager ensuring that no dirty read/write occurs.
ParallelClass([num_workers, ...])	Class to simplify the implementation of objects whose methods can be executed in parallel.
ParallelCounter([size, interval, lock, manager])
SharableListArr(arr, dtype)

Functions:

getCounter([size, interval])

class CircularParallelCounter(size=1, lock=None)

Bases: vemomoto_core.concurrent.nicepar.Lockable

Methods:

next()
reset()

next()

reset()

class Counter(size=1, interval=None)

Bases: object

Methods:

next()
reset()

next()

reset()

class DummyObj(parent)

Bases: object

Methods:

update()

update()

class DummyVar(value)

Bases: object

class Lockable(lock=None)

Bases: object

class Locked(parent)

Bases: object

Context manager ensuring that no dirty read/write occurs. Use with the “with” statement:

with Locked(self):

# do something that requires the object to be # accassible to this process only pass

class ParallelClass(num_workers=None, make_sharable_functions=[], exclude=[], prohibit_sharing=False)

Bases: vemomoto_core.concurrent.nicepar.Lockable

Class to simplify the implementation of objects whose methods can be executed in parallel.

Methods:

parmap(f, argList)	Executes f(arg) for arg in argList in parallel returns a list of the results in the same order as the arguments, invalid results (None) are ignored
postpone_task(f, *args)

parmap(f, argList)

Executes f(arg) for arg in argList in parallel returns a list of the results in the same order as the arguments, invalid results (None) are ignored

postpone_task(f, *args)

class ParallelCounter(size=1, interval=None, lock=None, manager=None)

Bases: vemomoto_core.concurrent.nicepar.Lockable

Methods:

next()
reset()

next()

reset()

class SharableListArr(arr, dtype)

Bases: object

getCounter(size=1, interval=None)