oqp.utils.mpi_utils

Attributes

mpi4py_available

Classes

`MPIManager`
`MPIPool`
`MPIMap`

Functions

`mpi_get_attr`(func)
`mpi_update_attr`(func)
`mpi_dump`(func)

Module Contents

mpi4py_available = True

class MPIManager

mpi4py_available()

barrier()

finalize_mpi()

set_mpi_comm(data)

bcast(data, root=0, barrier=True)

class MPIPool(processes)

processes

imap_unordered(func, inp)

close()

class MPIMap(func, var, processes)

Bases: collections.abc.Iterator

a = -1

func

var

processes

mpi_manager

mpi_get_attr(func)

mpi_update_attr(func)

mpi_dump(func)