Class BoundedByteBuffer

  • All Implemented Interfaces:

    public class BoundedByteBuffer
    extends java.lang.Object
    implements java.lang.AutoCloseable
    Buffer with buffering allowing One Writer and Multiple Readers. - Storage is done in a fixed size circular buffer ( - Reader & writers are synchronized using multiple Producer-Consumer locks : ( - Writer can write till circular buffer is full. Then it blocks until free space is available (ALL readers have read some data) - Reader cannot read till the Writer writes data to the circular buffer.
    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      class  BoundedByteBuffer.Writer
      Writes data to the BoundedByteBuffer At the end of data, should write and End Of File (EOF) using the writeEOF() method Closing the Writer without EOF would throw a IOException (Broken stream) Non thread safe.
    • Constructor Summary

      Constructor Description
      BoundedByteBuffer​(int bufferSize, int readerCount)  
    • Constructor Detail

      • BoundedByteBuffer

        public BoundedByteBuffer​(int bufferSize,
                                 int readerCount)
    • Method Detail

      • getReader

        public getReader​(int index)
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable