mapper - Parallel processing implementations

AMQPMapper

MPIMapper

MPMapper

SerialMapper

nice

setpriority

Set The Priority of a Windows Process.

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.