org.jboss.netty.handler.execution

Class 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

All Implemented Interfaces:

Executor, 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

Nested Class Summary

Nested classes/interfaces inherited from class org.jboss.netty.handler.execution.FairOrderedMemoryAwareThreadPoolExecutor

FairOrderedMemoryAwareThreadPoolExecutor.EventTask

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Field Summary

Fields inherited from class org.jboss.netty.handler.execution.FairOrderedMemoryAwareThreadPoolExecutor

map

Constructor Summary

Constructors

Constructor and Description
FairOrderedDownstreamThreadPoolExecutor(int corePoolSize) Creates a new instance.
FairOrderedDownstreamThreadPoolExecutor(int corePoolSize, long keepAliveTime, TimeUnit unit) Creates a new instance.
FairOrderedDownstreamThreadPoolExecutor(int corePoolSize, long keepAliveTime, TimeUnit unit, ThreadFactory threadFactory) Creates a new instance.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doExecute(Runnable task) Executes the specified task concurrently while maintaining the event order.
void	execute(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(Runnable task) Return false as we not need to count the memory in this implementation

Methods inherited from class org.jboss.netty.handler.execution.FairOrderedMemoryAwareThreadPoolExecutor

compareAndSetNext, getKey, newMap, removeKey

Methods inherited from class org.jboss.netty.handler.execution.MemoryAwareThreadPoolExecutor

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

Methods inherited from class 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

Methods inherited from class java.util.concurrent.AbstractExecutorService

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FairOrderedDownstreamThreadPoolExecutor

public FairOrderedDownstreamThreadPoolExecutor(int corePoolSize)

Creates a new instance.

Parameters:

corePoolSize - the maximum number of active threads

FairOrderedDownstreamThreadPoolExecutor

public FairOrderedDownstreamThreadPoolExecutor(int corePoolSize,
                                       long keepAliveTime,
                                       TimeUnit unit)

Creates a new instance.

Parameters:

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,
                                       TimeUnit unit,
                                       ThreadFactory threadFactory)

Creates a new instance.

Parameters:

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

Method Detail

getObjectSizeEstimator

public ObjectSizeEstimator getObjectSizeEstimator()

Return null

Overrides:

getObjectSizeEstimator in class MemoryAwareThreadPoolExecutor

setObjectSizeEstimator

public void setObjectSizeEstimator(ObjectSizeEstimator objectSizeEstimator)

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

Overrides:

setObjectSizeEstimator in class MemoryAwareThreadPoolExecutor

getMaxChannelMemorySize

public long getMaxChannelMemorySize()

Returns 0L

Overrides:

getMaxChannelMemorySize in class MemoryAwareThreadPoolExecutor

setMaxChannelMemorySize

public void setMaxChannelMemorySize(long maxChannelMemorySize)

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

Overrides:

setMaxChannelMemorySize in class MemoryAwareThreadPoolExecutor

getMaxTotalMemorySize

public long getMaxTotalMemorySize()

Returns 0L

Overrides:

getMaxTotalMemorySize in class MemoryAwareThreadPoolExecutor

shouldCount

protected boolean shouldCount(Runnable task)

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

Overrides:

shouldCount in class FairOrderedMemoryAwareThreadPoolExecutor

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

Overrides:

execute in class MemoryAwareThreadPoolExecutor

doExecute

protected void doExecute(Runnable task)

Executes the specified task concurrently while maintaining the event order.

Overrides:

doExecute in class FairOrderedMemoryAwareThreadPoolExecutor