程序包 | 说明 |
---|---|
org.jboss.netty.handler.execution |
Executor -based implementation of various
thread models that separate business logic from I/O threads |
org.jboss.netty.handler.traffic |
Implementation of a Traffic Shaping Handler and Dynamic Statistics.
|
org.jboss.netty.util |
Utility classes used across multiple packages.
|
限定符和类型 | 方法和说明 |
---|---|
ObjectSizeEstimator |
OrderedDownstreamThreadPoolExecutor.getObjectSizeEstimator()
Return
null |
ObjectSizeEstimator |
MemoryAwareThreadPoolExecutor.getObjectSizeEstimator()
Returns the
ObjectSizeEstimator of this pool. |
ObjectSizeEstimator |
FairOrderedDownstreamThreadPoolExecutor.getObjectSizeEstimator()
Return
null |
限定符和类型 | 方法和说明 |
---|---|
void |
OrderedDownstreamThreadPoolExecutor.setObjectSizeEstimator(ObjectSizeEstimator objectSizeEstimator)
Throws
UnsupportedOperationException as there is not support for limit the memory
size in this implementation |
void |
MemoryAwareThreadPoolExecutor.setObjectSizeEstimator(ObjectSizeEstimator objectSizeEstimator)
Sets the
ObjectSizeEstimator of this pool. |
void |
FairOrderedDownstreamThreadPoolExecutor.setObjectSizeEstimator(ObjectSizeEstimator objectSizeEstimator)
Throws
UnsupportedOperationException as there is not support for limit the memory size in this
implementation |
构造器和说明 |
---|
FairOrderedMemoryAwareThreadPoolExecutor(int corePoolSize,
long maxChannelMemorySize,
long maxTotalMemorySize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
ObjectSizeEstimator objectSizeEstimator,
java.util.concurrent.ThreadFactory threadFactory)
Creates a new instance.
|
MemoryAwareThreadPoolExecutor(int corePoolSize,
long maxChannelMemorySize,
long maxTotalMemorySize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
ObjectSizeEstimator objectSizeEstimator,
java.util.concurrent.ThreadFactory threadFactory)
Creates a new instance.
|
OrderedMemoryAwareThreadPoolExecutor(int corePoolSize,
long maxChannelMemorySize,
long maxTotalMemorySize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
ObjectSizeEstimator objectSizeEstimator,
java.util.concurrent.ThreadFactory threadFactory)
Creates a new instance.
|
限定符和类型 | 类和说明 |
---|---|
static class |
AbstractTrafficShapingHandler.SimpleObjectSizeEstimator
For simple ChannelBuffer, returns the readableBytes, else
use standard DefaultObjectSizeEstimator.
|
构造器和说明 |
---|
AbstractTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer)
|
AbstractTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long checkInterval)
Constructor using the specified ObjectSizeEstimator and using NO LIMIT and
default max time as delay allowed value of 15000L ms.
|
AbstractTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long writeLimit,
long readLimit)
|
AbstractTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long writeLimit,
long readLimit,
long checkInterval)
Constructor using the specified ObjectSizeEstimator and
default max time as delay allowed value of 15000L ms.
|
AbstractTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long writeLimit,
long readLimit,
long checkInterval,
long maxTime)
Constructor using the specified ObjectSizeEstimator.
|
ChannelTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer) |
ChannelTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long checkInterval) |
ChannelTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long writeLimit,
long readLimit) |
ChannelTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long writeLimit,
long readLimit,
long checkInterval) |
ChannelTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long writeLimit,
long readLimit,
long checkInterval,
long maxTime) |
GlobalChannelTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer) |
GlobalChannelTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long checkInterval) |
GlobalChannelTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long writeLimit,
long readLimit,
long writeChannelLimit,
long readChannelLimit) |
GlobalChannelTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long writeLimit,
long readLimit,
long writeChannelLimit,
long readChannelLimit,
long checkInterval) |
GlobalChannelTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long writeLimit,
long readLimit,
long writeChannelLimit,
long readChannelLimit,
long checkInterval,
long maxTime) |
GlobalTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer) |
GlobalTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long checkInterval) |
GlobalTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long writeLimit,
long readLimit) |
GlobalTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long writeLimit,
long readLimit,
long checkInterval) |
GlobalTrafficShapingHandler(ObjectSizeEstimator objectSizeEstimator,
Timer timer,
long writeLimit,
long readLimit,
long checkInterval,
long maxTime) |
限定符和类型 | 类和说明 |
---|---|
class |
DefaultObjectSizeEstimator
The default
ObjectSizeEstimator implementation for general purpose. |