Class AbstractSingleCoreIOReactor

java.lang.Object
org.apache.hc.core5.reactor.AbstractSingleCoreIOReactor
All Implemented Interfaces:
Closeable, AutoCloseable, ModalCloseable, IOReactor
Direct Known Subclasses:
SingleCoreIOReactor, SingleCoreListeningIOReactor

abstract class AbstractSingleCoreIOReactor extends Object implements IOReactor
  • Field Details

  • Constructor Details

    • AbstractSingleCoreIOReactor

      AbstractSingleCoreIOReactor(Callback<Exception> exceptionCallback)
  • Method Details

    • getStatus

      public final IOReactorStatus getStatus()
      Description copied from interface: IOReactor
      Returns the current status of the reactor.
      Specified by:
      getStatus in interface IOReactor
      Returns:
      reactor status.
    • logException

      void logException(Exception ex)
    • doExecute

      abstract void doExecute() throws IOException
      Throws:
      IOException
    • doTerminate

      abstract void doTerminate() throws IOException
      Throws:
      IOException
    • execute

      public void execute()
    • awaitShutdown

      public final void awaitShutdown(TimeValue waitTime) throws InterruptedException
      Description copied from interface: IOReactor
      Blocks for the given period of time in milliseconds awaiting the completion of the reactor shutdown.
      Specified by:
      awaitShutdown in interface IOReactor
      Parameters:
      waitTime - wait time.
      Throws:
      InterruptedException
    • initiateShutdown

      public final void initiateShutdown()
      Description copied from interface: IOReactor
      Initiates shutdown of the reactor without blocking. The reactor is expected to terminate all active connections, to shut down itself and to release system resources it currently holds
      Specified by:
      initiateShutdown in interface IOReactor
    • close

      public final void close(CloseMode closeMode)
      Description copied from interface: IOReactor
      Shuts down the I/O reactor either gracefully or immediately. During graceful shutdown individual I/O sessions should be informed about imminent termination and be given a grace period to complete the ongoing I/O sessions. During immediate shutdown all ongoing I/O sessions get aborted immediately.
      Specified by:
      close in interface IOReactor
      Specified by:
      close in interface ModalCloseable
      Parameters:
      closeMode - How to close the receiver.
    • close

      public void close(CloseMode closeMode, Timeout timeout)
      Shuts down the I/O reactor either gracefully or immediately. During graceful shutdown individual I/O sessions should be informed about imminent termination and be given a grace period to complete the ongoing I/O sessions. During immediate shutdown all ongoing I/O sessions get aborted immediately.
      Parameters:
      closeMode - How to close the IO reactor.
      timeout - How long to wait for the IO reactor to close gracefully.
      Since:
      5.2
    • close

      public final void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
    • toString

      public String toString()
      Overrides:
      toString in class Object