sfepy.base.multiproc_proc module

Multiprocessing functions - using multiprocessing (process based) module.

class sfepy.base.multiproc_proc.MyQueue[source]
get(self)[source]
put(self, value)[source]
sfepy.base.multiproc_proc.get_dict(name, clear=False, **kwargs)[source]

Get the remote dictionary.

sfepy.base.multiproc_proc.get_int_value(name, val0=0)[source]

Get the remote integer value.

sfepy.base.multiproc_proc.get_list(name, clear=False)[source]

Get the remote list.

sfepy.base.multiproc_proc.get_lock(name)[source]

Get the global lock.

sfepy.base.multiproc_proc.get_manager()[source]

Get the multiprocessing manager. If not in the global cache, create a new instance.

Returns
managermanager

The multiprocessing manager.

sfepy.base.multiproc_proc.get_mpdict_value(mode, key, clear=False)[source]

Get the item from the global multiprocessing cache.

Parameters
modestr

The type of the required object.

keyimmutable type

The key of the required object.

clearbool

If True, clear the dictionary or list (for modes ‘dict’ and ‘list’).

Returns
valueremote object

The remote object.

sfepy.base.multiproc_proc.get_queue(name)[source]

Get the global queue.

sfepy.base.multiproc_proc.is_remote_dict(d)[source]

Return True if ‘d’ is instance.