jacinle.comm.broadcast#

Classes

Functions

make_broadcast_pair(name[, nr_workers, ...])

Class BroadcastInputPipe

class BroadcastInputPipe[source]#

Bases: object

__init__(conn_info)[source]#
__new__(**kwargs)#
activate()[source]#
finalize()[source]#
initialize()[source]#
recv()[source]#

Class BroadcastOutputPipe

class BroadcastOutputPipe[source]#

Bases: object

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

Functions

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