Class NioClientBoss

  • All Implemented Interfaces:
    java.lang.Runnable, Boss, NioSelector

    public final class NioClientBoss
    extends AbstractNioSelector
    implements Boss
    Boss implementation that handles the connection attempts of clients
    • Field Detail

      • wakeupTask

        private final TimerTask wakeupTask
      • timer

        private final Timer timer
    • Constructor Detail

      • NioClientBoss

        NioClientBoss​(java.util.concurrent.Executor bossExecutor,
                      Timer timer,
                      ThreadNameDeterminer determiner)
    • Method Detail

      • processSelectedKeys

        private void processSelectedKeys​(java.util.Set<java.nio.channels.SelectionKey> selectedKeys)
      • processConnectTimeout

        private static void processConnectTimeout​(java.util.Set<java.nio.channels.SelectionKey> keys,
                                                  long currentTimeNanos)
      • connect

        private static void connect​(java.nio.channels.SelectionKey k)
                             throws java.io.IOException
        Throws:
        java.io.IOException