Constructor Detail

• Writer

  public Writer(RouterContext ctx)

  Writer.

Method Detail

• adjustThreads

  public void adjustThreads()

  Dynamically adjust thread count to match the target.

• connectionClosed

  public void connectionClosed(NTCPConnection con)

  connectionClosed.

• getActiveCount

  public int getActiveCount()

  Get the number of threads currently processing (not parked).

• getThreadCount

  public static int getThreadCount()

  Get the writer thread count

• getUtilization

  public double getUtilization()

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

  Returns:

  the utilization

• setThreadCount

  public static void setThreadCount(int count)

  Set the writer thread count, bounded by MIN_THREADS-MAX_THREADS

• startWriting

  public void startWriting(int numWriters)

  startWriting.

• stopWriting

  public void stopWriting()

  stopWriting.

• wantsWrite

  public void wantsWrite(NTCPConnection con,
                         String source)

  wantsWrite.