io.netty.channel

类 AdaptiveRecvByteBufAllocator

java.lang.Object

io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator

io.netty.channel.AdaptiveRecvByteBufAllocator

所有已实现的接口:

MaxMessagesRecvByteBufAllocator, RecvByteBufAllocator

public class AdaptiveRecvByteBufAllocator
extends DefaultMaxMessagesRecvByteBufAllocator

The RecvByteBufAllocator that automatically increases and decreases the predicted buffer size on feed back.

It gradually increases the expected number of readable bytes if the previous read fully filled the allocated buffer. It gradually decreases the expected number of readable bytes if the read operation was not able to fill a certain amount of the allocated buffer two times consecutively. Otherwise, it keeps returning the same prediction.

嵌套类概要

从类继承的嵌套类/接口 io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator

DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle

从接口继承的嵌套类/接口 io.netty.channel.RecvByteBufAllocator

RecvByteBufAllocator.DelegatingHandle, RecvByteBufAllocator.ExtendedHandle, RecvByteBufAllocator.Handle

字段概要

字段

限定符和类型	字段和说明
static AdaptiveRecvByteBufAllocator	DEFAULT 已过时。 There is state for DefaultMaxMessagesRecvByteBufAllocator.maxMessagesPerRead() which is typically based upon channel type.

构造器概要

构造器

构造器和说明
AdaptiveRecvByteBufAllocator() Creates a new predictor with the default parameters.
AdaptiveRecvByteBufAllocator(int minimum, int initial, int maximum) Creates a new predictor with the specified parameters.

方法概要

限定符和类型	方法和说明
RecvByteBufAllocator.Handle	newHandle() Creates a new handle.
AdaptiveRecvByteBufAllocator	respectMaybeMoreData(boolean respectMaybeMoreData) Determine if future instances of RecvByteBufAllocator.newHandle() will stop reading if we think there is no more data.

从类继承的方法 io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator

maxMessagesPerRead, maxMessagesPerRead, respectMaybeMoreData

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

DEFAULT

@Deprecated
public static final AdaptiveRecvByteBufAllocator DEFAULT

已过时。 There is state for DefaultMaxMessagesRecvByteBufAllocator.maxMessagesPerRead() which is typically based upon channel type.

构造器详细资料

AdaptiveRecvByteBufAllocator

public AdaptiveRecvByteBufAllocator()

Creates a new predictor with the default parameters. With the default parameters, the expected buffer size starts from 1024, does not go down below 64, and does not go up above 65536.

AdaptiveRecvByteBufAllocator

public AdaptiveRecvByteBufAllocator(int minimum,
                                    int initial,
                                    int maximum)

Creates a new predictor with the specified parameters.

参数:

minimum - the inclusive lower bound of the expected buffer size

initial - the initial buffer size when no feed back was received

maximum - the inclusive upper bound of the expected buffer size

方法详细资料

newHandle

public RecvByteBufAllocator.Handle newHandle()

从接口复制的说明: RecvByteBufAllocator

Creates a new handle. The handle provides the actual operations and keeps the internal information which is required for predicting an optimal buffer capacity.

respectMaybeMoreData

public AdaptiveRecvByteBufAllocator respectMaybeMoreData(boolean respectMaybeMoreData)

从类复制的说明: DefaultMaxMessagesRecvByteBufAllocator

Determine if future instances of RecvByteBufAllocator.newHandle() will stop reading if we think there is no more data.

覆盖:

respectMaybeMoreData 在类中 DefaultMaxMessagesRecvByteBufAllocator

参数:

respectMaybeMoreData -

• true to stop reading if we think there is no more data. This may save a system call to read from the socket, but if data has arrived in a racy fashion we may give up our DefaultMaxMessagesRecvByteBufAllocator.maxMessagesPerRead() quantum and have to wait for the selector to notify us of more data.
• false to keep reading (up to DefaultMaxMessagesRecvByteBufAllocator.maxMessagesPerRead()) or until there is no data when we attempt to read.

返回:

this.