org.jboss.netty.handler.execution

类 FairOrderedDownstreamThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.jboss.netty.handler.execution.MemoryAwareThreadPoolExecutor

org.jboss.netty.handler.execution.FairOrderedMemoryAwareThreadPoolExecutor

org.jboss.netty.handler.execution.FairOrderedDownstreamThreadPoolExecutor

所有已实现的接口:

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

public final class FairOrderedDownstreamThreadPoolExecutor
extends FairOrderedMemoryAwareThreadPoolExecutor

This is a fair alternative of OrderedDownstreamThreadPoolExecutor .

For more information about how the order is preserved see FairOrderedMemoryAwareThreadPoolExecutor

嵌套类概要

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

FairOrderedMemoryAwareThreadPoolExecutor.EventTask

从类继承的嵌套类/接口 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.FairOrderedMemoryAwareThreadPoolExecutor

map

构造器概要

构造器

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

方法概要

方法

限定符和类型	方法和说明
protected void	doExecute(java.lang.Runnable task) Executes the specified task concurrently while maintaining the event order.
void	execute(java.lang.Runnable command)
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 count the memory in this implementation

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

compareAndSetNext, getKey, newMap, removeKey

从类继承的方法 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

构造器详细资料

FairOrderedDownstreamThreadPoolExecutor

public FairOrderedDownstreamThreadPoolExecutor(int corePoolSize)

Creates a new instance.

参数:

corePoolSize - the maximum number of active threads

FairOrderedDownstreamThreadPoolExecutor

public FairOrderedDownstreamThreadPoolExecutor(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

FairOrderedDownstreamThreadPoolExecutor

public FairOrderedDownstreamThreadPoolExecutor(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 count the memory in this implementation

覆盖:

shouldCount 在类中 FairOrderedMemoryAwareThreadPoolExecutor

execute

public void execute(java.lang.Runnable command)

指定者:

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

覆盖:

execute 在类中 MemoryAwareThreadPoolExecutor

doExecute

protected void doExecute(java.lang.Runnable task)

Executes the specified task concurrently while maintaining the event order.

覆盖:

doExecute 在类中 FairOrderedMemoryAwareThreadPoolExecutor