local_comm

T = TypeVar('T') module-attribute

ConcurrencyError

Bases: Exception

Exception to denote that a rank cannot proceed because it is waiting on a call from another rank.

AsyncResult

__init__(result)

wait()

LocalComm

Bases: Comm[T]

rank = rank instance-attribute

total_ranks = total_ranks instance-attribute

__init__(rank, total_ranks, buffer_dict)

Get_rank()

Get_size()

bcast(value, root=0)

Barrier()

barrier()

Scatter(sendbuf, recvbuf, root=0, **kwargs)

Gather(sendbuf, recvbuf, root=0, **kwargs)

allgather(sendobj)

Send(sendbuf, dest, tag=0, **kwargs)

Isend(sendbuf, dest, tag=0, **kwargs)

Recv(recvbuf, source, tag=0, **kwargs)

Irecv(recvbuf, source, tag=0, **kwargs)

sendrecv(sendbuf, dest, **kwargs)

Split(color, key)

allreduce(sendobj, op=None, recvobj=None)

Allreduce(sendobj, recvobj, op)

Allreduce_inplace(obj, op)