NTCPSendFinisher (Javadocs [I2P+ 2.13.0+]

java.lang.Object
- net.i2p.router.transport.ntcp.NTCPSendFinisher

```
class NTCPSendFinisher
extends Object
```
Handles asynchronous post-send processing of OutNetMessage using a dynamically resizable thread pool executor with a bounded queue and backpressure. Provides efficient message serialization and prevents resource exhaustion.

Constructor Summary
Constructors
Constructor and Description
NTCPSendFinisher(I2PAppContext context, NTCPTransport transport)
Create a new send finisher.

Constructors
Constructor and Description
`NTCPSendFinisher(I2PAppContext context, NTCPTransport transport)` Create a new send finisher.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`add(OutNetMessage msg)` Adds a message to the finishing queue to call afterSend asynchronously.
`void`	`adjustThreads(int newMax)` Adjusts the thread pool size for the running executor.
`int`	`getActiveCount()` Returns the number of threads currently processing tasks.
`static int`	`getMaxThreads()` Returns the current max send finisher threads.
`int`	`getPoolSize()` Returns the current pool size (total threads).
`static int`	`getQueueCapacity()` Returns the current send finisher queue capacity.
`int`	`getQueueSize()` Returns the current queue size (pending send-finish tasks).
`double`	`getUtilization()` Get send finisher pool utilization as a ratio (0.0-1.0).
`static void`	`setMaxThreads(int threads)` Sets the max send finisher threads for new instances.
`static void`	`setQueueCapacity(int capacity)` Sets the send finisher queue capacity for new instances.
`void`	`start()` Starts the thread pool executor for processing send finish tasks.
`void`	`stop()` Stops the thread pool executor, waiting briefly for termination.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - NTCPSendFinisher
```
public NTCPSendFinisher(I2PAppContext context,
                        NTCPTransport transport)
```
    Create a new send finisher.
    Parameters:
    context - the I2P app context
    transport - the NTCP transport
- Method Detail
  - add
```
public void add(OutNetMessage msg)
```
    Adds a message to the finishing queue to call afterSend asynchronously. If the executor is stopped or saturated, falls back to caller running the task.
    Parameters:
    msg - the message to process after sending
  - adjustThreads
```
public void adjustThreads(int newMax)
```
    Adjusts the thread pool size for the running executor. If the pool is not running, this is a no-op (new size takes effect on next start).
    Parameters:
    newMax - the new max thread count
  - getActiveCount
```
public int getActiveCount()
```
    Returns the number of threads currently processing tasks.
    Returns:
    active thread count, or 0 if not running
  - getMaxThreads
```
public static int getMaxThreads()
```
    Returns the current max send finisher threads.
    Returns:
    the max thread count
  - getPoolSize
```
public int getPoolSize()
```
    Returns the current pool size (total threads).
    Returns:
    pool size, or 0 if not running
  - getQueueCapacity
```
public static int getQueueCapacity()
```
    Returns the current send finisher queue capacity.
    Returns:
    the queue capacity
  - getQueueSize
```
public int getQueueSize()
```
    Returns the current queue size (pending send-finish tasks).
    Returns:
    current queue depth, or 0 if not running
  - getUtilization
```
public double getUtilization()
```
    Get send finisher pool utilization as a ratio (0.0-1.0). Returns NaN if pool not started.
    Returns:
    the utilization ratio
  - setMaxThreads
```
public static void setMaxThreads(int threads)
```
    Sets the max send finisher threads for new instances.
    Parameters:
    threads - the new max thread count
  - setQueueCapacity
```
public static void setQueueCapacity(int capacity)
```
    Sets the send finisher queue capacity for new instances.
    Parameters:
    capacity - the new queue capacity
  - start
```
public void start()
```
    Starts the thread pool executor for processing send finish tasks.
  - stop
```
public void stop()
```
    Stops the thread pool executor, waiting briefly for termination.

Class NTCPSendFinisher

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

NTCPSendFinisher

Method Detail

add

adjustThreads

getActiveCount

getMaxThreads

getPoolSize

getQueueCapacity

getQueueSize

getUtilization

setMaxThreads

setQueueCapacity

start

stop