net.gleamynode.netty.handler.execution
Class OrderedMemoryAwareThreadPoolExecutor

java.lang.Object
  java.util.concurrent.AbstractExecutorService
      java.util.concurrent.ThreadPoolExecutor
          net.gleamynode.netty.handler.execution.MemoryAwareThreadPoolExecutor
              net.gleamynode.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService

public class OrderedMemoryAwareThreadPoolExecutor
extends MemoryAwareThreadPoolExecutor

Version:

$Rev$, $Date$

Author:

The Netty Project (netty@googlegroups.com), Trustin Lee (trustin@gmail.com), David M. Lloyd (david.lloyd@redhat.com)

Nested Class Summary

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

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

Constructor Summary

OrderedMemoryAwareThreadPoolExecutor(int corePoolSize, int maxChannelMemorySize, int maxTotalMemorySize)

OrderedMemoryAwareThreadPoolExecutor(int corePoolSize, int maxChannelMemorySize, int maxTotalMemorySize, long keepAliveTime, TimeUnit unit)

OrderedMemoryAwareThreadPoolExecutor(int corePoolSize, int maxChannelMemorySize, int maxTotalMemorySize, long keepAliveTime, TimeUnit unit, ObjectSizeEstimator objectSizeEstimator, ThreadFactory threadFactory)

OrderedMemoryAwareThreadPoolExecutor(int corePoolSize, int maxChannelMemorySize, int maxTotalMemorySize, long keepAliveTime, TimeUnit unit, ThreadFactory threadFactory)

Method Summary

protected void

doExecute(Runnable task)

Methods inherited from class net.gleamynode.netty.handler.execution.MemoryAwareThreadPoolExecutor

beforeExecute, doUnorderedExecute, execute, getMaxChannelMemorySize, getMaxTotalMemorySize, getObjectSizeEstimator, remove, setMaxChannelMemorySize, setMaxTotalMemorySize

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, shutdownNow, terminated

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, toString, wait, wait, wait

Constructor Detail

OrderedMemoryAwareThreadPoolExecutor

public OrderedMemoryAwareThreadPoolExecutor(int corePoolSize,
                                            int maxChannelMemorySize,
                                            int maxTotalMemorySize,
                                            long keepAliveTime,
                                            TimeUnit unit,
                                            ObjectSizeEstimator objectSizeEstimator,
                                            ThreadFactory threadFactory)

OrderedMemoryAwareThreadPoolExecutor

public OrderedMemoryAwareThreadPoolExecutor(int corePoolSize,
                                            int maxChannelMemorySize,
                                            int maxTotalMemorySize,
                                            long keepAliveTime,
                                            TimeUnit unit,
                                            ThreadFactory threadFactory)

OrderedMemoryAwareThreadPoolExecutor

public OrderedMemoryAwareThreadPoolExecutor(int corePoolSize,
                                            int maxChannelMemorySize,
                                            int maxTotalMemorySize,
                                            long keepAliveTime,
                                            TimeUnit unit)

OrderedMemoryAwareThreadPoolExecutor

public OrderedMemoryAwareThreadPoolExecutor(int corePoolSize,
                                            int maxChannelMemorySize,
                                            int maxTotalMemorySize)

Method Detail

doExecute

protected void doExecute(Runnable task)

Overrides:

doExecute in class MemoryAwareThreadPoolExecutor