mapper - Parallel processing implementations
Parallel and serial mapper implementations.
-
class
bumps.mapper.
AMQPMapper
[source]
Bases: object
-
static
start_mapper
(problem, modelargs, cpus=0)[source]
-
static
start_worker
(problem)[source]
-
static
stop_mapper
(mapper)[source]
-
class
bumps.mapper.
MPIMapper
[source]
Bases: object
-
static
start_mapper
(problem, modelargs, cpus=0)[source]
-
static
start_worker
(problem)[source]
-
static
stop_mapper
(mapper)[source]
-
class
bumps.mapper.
MPMapper
[source]
Bases: object
-
static
can_pickle
(problem, check=False)[source]
Returns True if problem can be pickled.
If this method returns False then MPMapper cannot be used and
SerialMapper should be used instead.
If check is True then call nllf() on the duplicated object. This
will not be a foolproof check. If the model uses ephemeral objects,
such as a handle to an external process or similar, then handle might
be copied and accessible locally but not be accessible to the remote
process.
-
manager
= None
-
namespace
= None
-
pool
= None
-
problem_id
= 0
-
static
start_mapper
(problem, modelargs, cpus=0)[source]
-
static
start_worker
(problem)[source]
-
static
stop_mapper
(mapper)[source]
-
class
bumps.mapper.
SerialMapper
[source]
Bases: object
-
static
start_mapper
(problem, modelargs, cpus=0)[source]
-
static
start_worker
(problem)[source]
-
static
stop_mapper
(mapper)[source]
-
bumps.mapper.
nice
()[source]
-
bumps.mapper.
setpriority
(pid=None, priority=1)[source]
Set The Priority of a Windows Process. Priority is a value between 0-5
where 2 is normal priority and 5 is maximum. Default sets the priority
of the current python process but can take any valid process ID.