java.lang.Object
net.i2p.data.i2cp.I2CPMessageReader.I2CPMessageReaderRunner
All Implemented Interfaces:
Runnable
Enclosing class:
I2CPMessageReader
protected class I2CPMessageReader.I2CPMessageReaderRunnerextends Object implements Runnable
I2CPMessageReaderRunner.

  • Field Details

    • _doRun

      protected volatile boolean _doRun
      Whether the read loop should keep reading.

    • _stayAlive

      protected volatile boolean _stayAlive
      Whether the reader thread should stay alive past the last message.

    • _log

      private final Log _log
      Logger for this class.

  • Constructor Details

    • I2CPMessageReaderRunner

      public I2CPMessageReaderRunner()
      I2CPMessageReaderRunner.

  • Method Details

    • pauseRunner

      public void pauseRunner()
      Pause the reader loop.

    • resumeRunner

      public void resumeRunner()
      Resume the reader loop.

    • cancelRunner

      public void cancelRunner()
      Cancel the message reading loop and close the stream.

    • run

      public void run()
      Run the message reading loop.
      Specified by:
      run in interface Runnable

    • run2

      protected void run2()
      Called by run().