Reader (Javadocs [I2P+ 2.13.0+] - API Version 0.9.70+)

Skip navigation links

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

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

```
public class Reader
extends Object
```
Pool of running threads which will process any read bytes on any of the NTCPConnections, including decryption of the data read, connection handshaking, parsing bytes into I2NP messages, etc. Provides efficient buffer management and connection lifecycle coordination. Supports dynamic thread count adjustment via adjustThreads().

Constructor Summary
Constructors
Constructor and Description
Reader(RouterContext ctx)
Constructor.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`adjustThreads()` Dynamically adjust thread count to match the target.
`void`	`connectionClosed(NTCPConnection con)` Description.
`int`	`getActiveCount()` Get the number of threads currently processing (not parked).
`static int`	`getThreadCount()` Get the reader thread count
`double`	`getUtilization()` Get reader pool utilization as a ratio (0.0-1.0).
`static void`	`setThreadCount(int count)` Set the reader thread count, bounded by MIN_THREADS-MAX_THREADS
`void`	`startReading(int numReaders)` Description.
`void`	`stopReading()` Description.
`void`	`wantsRead(NTCPConnection con)` Description.

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

- Constructor Detail
  - Reader
```
public Reader(RouterContext ctx)
```
    Constructor.
- Method Detail
  - adjustThreads
```
public void adjustThreads()
```
    Dynamically adjust thread count to match the target.
  - connectionClosed
```
public void connectionClosed(NTCPConnection con)
```
    Description.
  - getActiveCount
```
public int getActiveCount()
```
    Get the number of threads currently processing (not parked).
  - getThreadCount
```
public static int getThreadCount()
```
    Get the reader thread count
  - getUtilization
```
public double getUtilization()
```
    Get reader pool utilization as a ratio (0.0-1.0). Returns NaN if no runners are active (pool not started).
    Returns:
    the utilization
  - setThreadCount
```
public static void setThreadCount(int count)
```
    Set the reader thread count, bounded by MIN_THREADS-MAX_THREADS
  - startReading
```
public void startReading(int numReaders)
```
    Description.
  - stopReading
```
public void stopReading()
```
    Description.
  - wantsRead
```
public void wantsRead(NTCPConnection con)
```
    Description.

Skip navigation links

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method