Public Member Functions | |
| def | __init__ (self, capacity, schema=None, name='queue') |
| def | setup (self, global_init_net) |
Public Member Functions inherited from queue_util.QueueWrapper | |
| def | __init__ (self, handler, schema=None) |
| def | reader (self) |
| def | writer (self) |
| def | queue (self) |
Public Member Functions inherited from dataio.Pipe | |
| def | __init__ (self, schema=None, obj_key=None) |
| def | schema (self) |
| def | setup (self, global_init_net) |
| def | reader (self) |
| def | writer (self) |
| def | num_readers (self) |
| def | num_writers (self) |
Public Attributes | |
| capacity | |
Definition at line 62 of file queue_util.py.
1.8.14