ReadHandleFactory that always yields the same buffer
size prediction. This handle ignores the feedback from the I/O thread.
| Modifier and Type | Class and Description |
|---|---|
| private static class |
| Modifier and Type | Field and Description |
|---|---|
| private final int |
| Access | Constructor and Description |
|---|---|
| public | FixedReadHandleFactory(int bufferSize)
Creates a new predictor that always returns the same prediction of the specified buffer size. |
| public |
| Modifier and Type | Method and Description |
|---|---|
| public MaxMessagesReadHandleFactory. | newMaxMessageHandle(int
the maximum number of messages to read per read loop. maxMessagesPerRead)Implements abstract io. MaxMessageReadHandle to use.
|
| bufferSize | back to summary |
|---|---|
| private final int bufferSize | |
| FixedReadHandleFactory | back to summary |
|---|---|
| public FixedReadHandleFactory(int bufferSize) Creates a new predictor that always returns the same prediction of the specified buffer size. | |
| FixedReadHandleFactory | back to summary |
|---|---|
| public FixedReadHandleFactory(int maxMessagesPerRead, int bufferSize) | |
| newMaxMessageHandle | back to summary |
|---|---|
| public MaxMessagesReadHandleFactory. Implements abstract io. Doc from io. Creates a new
| |
| Modifier and Type | Field and Description |
|---|---|
| private final int |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public int | estimatedBufferCapacity()
Implements io. |
| bufferSize | back to summary |
|---|---|
| private final int bufferSize | |
| ReadHandleImpl | back to summary |
|---|---|
| pack-priv ReadHandleImpl(int maxMessagesPerRead, int bufferSize) | |
| estimatedBufferCapacity | back to summary |
|---|---|
| public int estimatedBufferCapacity() Implements io. Doc from io. Guess the capacity for the next receive buffer that is probably large enough to read all inbound data and small enough not to waste its space.
| |