Class NonBlockingPumpReader

All Implemented Interfaces:
Closeable, AutoCloseable, Readable

public class NonBlockingPumpReader extends NonBlockingReader
  • Field Details

    • DEFAULT_BUFFER_SIZE

      private static final int DEFAULT_BUFFER_SIZE
      See Also:
    • buffer

      private final char[] buffer
    • read

      private int read
    • write

      private int write
    • count

      private int count
    • lock

      final ReentrantLock lock
      Main lock guarding all access
    • notEmpty

      private final Condition notEmpty
      Condition for waiting takes
    • notFull

      private final Condition notFull
      Condition for waiting puts
    • writer

      private final Writer writer
    • closed

      private boolean closed
  • Constructor Details

    • NonBlockingPumpReader

      public NonBlockingPumpReader()
    • NonBlockingPumpReader

      public NonBlockingPumpReader(int bufferSize)
  • Method Details