ringbuffer
ringbuffer copied to clipboard
bslatkin
Ring buffer that allows for high-throughput data transfer between multiproccessing Python processes.
Once you know how far behind you are with #3, it'd be nice if a reader can elect to zip forward to sync with the writer and skip a bunch...
This would allow the reader to understand how far behind the writer they are, as a number of slots. You could also return this value as a percentage of total...
The idea is you called this first and it would return a buffer for the next available slot. The reader wouldn't be able to get to this buffer yet. You'd...
Similar idea to #1 except for readers. The idea is you'd quickly get a handle on a slot. Then you could have a ctypes.Structure map to it using from_buffer(). You'd...