Constructor Detail

• Writer

  public Writer(RouterContext ctx)

  Writer 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()

  Writer thread count.

• getUtilization

  public double getUtilization()

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

  Returns:

  the utilization

• setThreadCount

  public static void setThreadCount(int count)

  Writer thread count, bounded by MIN_THREADS-MAX_THREADS.

• startWriting

  public void startWriting(int numWriters)

  Starts the given number of writer threads.

• stopWriting

  public void stopWriting()

  Stops all writer threads.

• wantsWrite

  public void wantsWrite(NTCPConnection con,
                         String source)

  Registers a connection to be written.