Class InProc

An established communication based on a pair of in-process queues.

Declaration

class InProc(Comm)

Reminder: a Comm must always be used from a single thread.
Its peer Comm can be running in any thread.

▶ def __init__(self, local_addr, peer_addr, read_q, write_q, write_loop, deserialize=True) override
source link
This method overrides distributed.comm.core.Comm.__init__.
▶ def abort(self) override
inherited doc Close the communication immediately and abruptly. Useful in destructors or generators' ``finally`` blocks.
source link
This method overrides distributed.comm.core.Comm.abort.
▶ def closed(self) override
Whether this comm is closed. An InProc comm is closed if:
source link
This method overrides distributed.comm.core.Comm.closed.
```
1) close() or abort() was called on this comm
2) close() or abort() was called on the other end and the
   read queue is empty
```
▶ def local_address(self) override @property
inherited doc The local address. For logging and debugging purposes only.
@property
def local_address(self)
source link
This method overrides distributed.comm.core.Comm.local_address.
▶ def peer_address(self) override @property
inherited doc The peer's address. For logging and debugging purposes only.
@property
def peer_address(self)
source link
This method overrides distributed.comm.core.Comm.peer_address.