Class NioEndpoint.SocketProcessor

  • All Implemented Interfaces:
    java.lang.Runnable
    Enclosing class:
    NioEndpoint

    protected class NioEndpoint.SocketProcessor
    extends SocketProcessorBase<NioChannel>
    This class is the equivalent of the Worker, but will simply use in an external Executor thread pool.
    • Constructor Detail

      • SocketProcessor

        public SocketProcessor​(SocketWrapperBase<NioChannel> socketWrapper,
                               SocketEvent event)
        Creates a new socket processor.
        Parameters:
        socketWrapper - The socket wrapper
        event - The socket event
    • Method Detail

      • doRun

        protected void doRun()
        Description copied from class: SocketProcessorBase
        Performs the actual socket processing work. Subclasses implement this method to define the specific processing logic for each endpoint type.
        Specified by:
        doRun in class SocketProcessorBase<NioChannel>