Skip to content

`pymor.parallel.mpi`¶

Module Contents¶

Classes¶

WorkerPool based pyMOR's MPI event loop.

Functions¶

`_worker_call_function`
`_single_worker_call_function`
`_worker_map_function`
`_setup_worker`
`_push_object`

class pymor.parallel.mpi.MPIPool[source]¶

Bases: pymor.parallel.basic.WorkerPoolBase

WorkerPool based pyMOR’s MPI event loop.

__del__(self)[source]¶

__len__(self)[source]¶: The number of workers in the pool.

_push_object(self, obj)[source]¶

_apply(self, function, *args, **kwargs)[source]¶

_apply_only(self, function, worker, *args, **kwargs)[source]¶

_map(self, function, chunks, **kwargs)[source]¶

_remove_object(self, remote_id)[source]¶

pymor.parallel.mpi._worker_call_function(function, *args, **kwargs)[source]¶

pymor.parallel.mpi._single_worker_call_function(payload, worker)[source]¶

pymor.parallel.mpi._worker_map_function(payload, function, **kwargs)[source]¶

pymor.parallel.mpi._setup_worker()[source]¶

pymor.parallel.mpi._push_object(obj)[source]¶