org.jboss.netty.handler.execution

类 OrderedDownstreamThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.jboss.netty.handler.execution.MemoryAwareThreadPoolExecutor

org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor

org.jboss.netty.handler.execution.OrderedDownstreamThreadPoolExecutor

所有已实现的接口:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService

public final class OrderedDownstreamThreadPoolExecutor
extends OrderedMemoryAwareThreadPoolExecutor

Executor which should be used for downstream ChannelEvent's. This implementation will take care of preserve the order of the events in a Channel. If you don't need to preserve the order just use one of the Executor implementations provided by the static methods of Executors.

For more informations about how the order is preserved see OrderedMemoryAwareThreadPoolExecutor

嵌套类概要

从类继承的嵌套类/接口 org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor

OrderedMemoryAwareThreadPoolExecutor.ChildExecutor

从类继承的嵌套类/接口 java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

字段概要

从类继承的字段 org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor

childExecutors

构造器概要

构造器

构造器和说明
OrderedDownstreamThreadPoolExecutor(int corePoolSize) Creates a new instance.
OrderedDownstreamThreadPoolExecutor(int corePoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit) Creates a new instance.
OrderedDownstreamThreadPoolExecutor(int corePoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.ThreadFactory threadFactory) Creates a new instance.

方法概要

方法

限定符和类型	方法和说明
void	execute(java.lang.Runnable command)
protected java.util.concurrent.Executor	getChildExecutor(ChannelEvent e)
long	getMaxChannelMemorySize() Returns 0L
long	getMaxTotalMemorySize() Returns 0L
ObjectSizeEstimator	getObjectSizeEstimator() Return null
void	setMaxChannelMemorySize(long maxChannelMemorySize) Throws UnsupportedOperationException as there is not support for limit the memory size in this implementation
void	setObjectSizeEstimator(ObjectSizeEstimator objectSizeEstimator) Throws UnsupportedOperationException as there is not support for limit the memory size in this implementation
protected boolean	shouldCount(java.lang.Runnable task) Return false as we not need to cound the memory in this implementation

从类继承的方法 org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor

doExecute, getChildExecutorKey, getChildExecutorKeySet, newChildExecutorMap, removeChildExecutor

从类继承的方法 org.jboss.netty.handler.execution.MemoryAwareThreadPoolExecutor

beforeExecute, decreaseCounter, doUnorderedExecute, getNotifyChannelFuturesOnShutdown, increaseCounter, remove, setNotifyChannelFuturesOnShutdown, shutdownNow, shutdownNow, terminated

从类继承的方法 java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, toString

从类继承的方法 java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

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

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

构造器详细资料

OrderedDownstreamThreadPoolExecutor

public OrderedDownstreamThreadPoolExecutor(int corePoolSize)

Creates a new instance.

参数:

corePoolSize - the maximum number of active threads

OrderedDownstreamThreadPoolExecutor

public OrderedDownstreamThreadPoolExecutor(int corePoolSize,
                                   long keepAliveTime,
                                   java.util.concurrent.TimeUnit unit)

Creates a new instance.

参数:

corePoolSize - the maximum number of active threads

keepAliveTime - the amount of time for an inactive thread to shut itself down

unit - the TimeUnit of keepAliveTime

OrderedDownstreamThreadPoolExecutor

public OrderedDownstreamThreadPoolExecutor(int corePoolSize,
                                   long keepAliveTime,
                                   java.util.concurrent.TimeUnit unit,
                                   java.util.concurrent.ThreadFactory threadFactory)

Creates a new instance.

参数:

corePoolSize - the maximum number of active threads

keepAliveTime - the amount of time for an inactive thread to shut itself down

unit - the TimeUnit of keepAliveTime

threadFactory - the ThreadFactory of this pool

方法详细资料

getObjectSizeEstimator

public ObjectSizeEstimator getObjectSizeEstimator()

Return null

覆盖:

getObjectSizeEstimator 在类中 MemoryAwareThreadPoolExecutor

setObjectSizeEstimator

public void setObjectSizeEstimator(ObjectSizeEstimator objectSizeEstimator)

Throws UnsupportedOperationException as there is not support for limit the memory size in this implementation

覆盖:

setObjectSizeEstimator 在类中 MemoryAwareThreadPoolExecutor

getMaxChannelMemorySize

public long getMaxChannelMemorySize()

Returns 0L

覆盖:

getMaxChannelMemorySize 在类中 MemoryAwareThreadPoolExecutor

setMaxChannelMemorySize

public void setMaxChannelMemorySize(long maxChannelMemorySize)

Throws UnsupportedOperationException as there is not support for limit the memory size in this implementation

覆盖:

setMaxChannelMemorySize 在类中 MemoryAwareThreadPoolExecutor

getMaxTotalMemorySize

public long getMaxTotalMemorySize()

Returns 0L

覆盖:

getMaxTotalMemorySize 在类中 MemoryAwareThreadPoolExecutor

shouldCount

protected boolean shouldCount(java.lang.Runnable task)

Return false as we not need to cound the memory in this implementation

覆盖:

shouldCount 在类中 OrderedMemoryAwareThreadPoolExecutor

execute

public void execute(java.lang.Runnable command)

指定者:

execute 在接口中 java.util.concurrent.Executor

覆盖:

execute 在类中 MemoryAwareThreadPoolExecutor

getChildExecutor

protected java.util.concurrent.Executor getChildExecutor(ChannelEvent e)

覆盖:

getChildExecutor 在类中 OrderedMemoryAwareThreadPoolExecutor