Constructor Detail

• Reader

  public Reader(RouterContext ctx)

  Reader thread pool for the given context.

Method Detail

• adjustThreads

  public void adjustThreads()

  Dynamically adjust thread count to match the target.

• connectionClosed

  public void connectionClosed(NTCPConnection con)

  Removes a closed connection from the queues.

• getActiveCount

  public int getActiveCount()

  Number of threads currently processing (not parked).

• getThreadCount

  public static int getThreadCount()

  Reader thread count.

• getUtilization

  public double getUtilization()

  Reader pool utilization as a ratio (0.0-1.0). NaN if no runners are active (pool not started).

  Returns:

  the utilization

• setThreadCount

  public static void setThreadCount(int count)

  Reader thread count, bounded by MIN_THREADS-MAX_THREADS

• startReading

  public void startReading(int numReaders)

  Starts the given number of reader threads.

• stopReading

  public void stopReading()

  Stop all reader threads.

• wantsRead

  public void wantsRead(NTCPConnection con)

  Registers a connection to be read.