jacinle.comm.gather#

Classes

Functions

make_gather_pair(name[, nr_workers, mode, ...])

Class GatherInputPipe

class GatherInputPipe[source]#

Bases: object

__init__(name, mode='tcp')[source]#
__new__(**kwargs)#
activate()[source]#
finalize()[source]#
initialize()[source]#
recv()[source]#
property conn_info#

Class GatherOutputPipe

class GatherOutputPipe[source]#

Bases: object

__init__(conn_info, send_qsize=10)[source]#
__new__(**kwargs)#
activate()[source]#
finalize()[source]#
initialize()[source]#
mainloop_send()[source]#
send(payload)[source]#

Functions

make_gather_pair(name, nr_workers=None, mode='tcp', send_qsize=10)[source]#