org.apache.mina.filter.executor
Class OrderedThreadPoolExecutor
java.lang.Object
java.util.concurrent.AbstractExecutorService
java.util.concurrent.ThreadPoolExecutor
org.apache.mina.filter.executor.OrderedThreadPoolExecutor
- All Implemented Interfaces:
- Executor, ExecutorService
public class OrderedThreadPoolExecutor
- extends ThreadPoolExecutor
A ThreadPoolExecutor
that maintains the order of IoEvent
s.
If you don't need to maintain the order of events per session, please use
UnorderedThreadPoolExecutor
.
- Version:
- $Rev: 595549 $, $Date: 2007-11-16 05:45:36 +0100 (Fri, 16 Nov 2007) $
- Author:
- The Apache MINA Project (dev@mina.apache.org)
Constructor Summary |
OrderedThreadPoolExecutor()
|
OrderedThreadPoolExecutor(int maximumPoolSize)
|
OrderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize)
|
OrderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit)
|
OrderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
IoEventQueueHandler queueHandler)
|
OrderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
ThreadFactory threadFactory)
|
OrderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
ThreadFactory threadFactory,
IoEventQueueHandler queueHandler)
|
OrderedThreadPoolExecutor
public OrderedThreadPoolExecutor()
OrderedThreadPoolExecutor
public OrderedThreadPoolExecutor(int maximumPoolSize)
OrderedThreadPoolExecutor
public OrderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize)
OrderedThreadPoolExecutor
public OrderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit)
OrderedThreadPoolExecutor
public OrderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
IoEventQueueHandler queueHandler)
OrderedThreadPoolExecutor
public OrderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
ThreadFactory threadFactory)
OrderedThreadPoolExecutor
public OrderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
ThreadFactory threadFactory,
IoEventQueueHandler queueHandler)
getQueueHandler
public IoEventQueueHandler getQueueHandler()
setRejectedExecutionHandler
public void setRejectedExecutionHandler(RejectedExecutionHandler handler)
- Overrides:
setRejectedExecutionHandler
in class ThreadPoolExecutor
getMaximumPoolSize
public int getMaximumPoolSize()
- Overrides:
getMaximumPoolSize
in class ThreadPoolExecutor
setMaximumPoolSize
public void setMaximumPoolSize(int maximumPoolSize)
- Overrides:
setMaximumPoolSize
in class ThreadPoolExecutor
awaitTermination
public boolean awaitTermination(long timeout,
TimeUnit unit)
throws InterruptedException
- Specified by:
awaitTermination
in interface ExecutorService
- Overrides:
awaitTermination
in class ThreadPoolExecutor
- Throws:
InterruptedException
isShutdown
public boolean isShutdown()
- Specified by:
isShutdown
in interface ExecutorService
- Overrides:
isShutdown
in class ThreadPoolExecutor
isTerminated
public boolean isTerminated()
- Specified by:
isTerminated
in interface ExecutorService
- Overrides:
isTerminated
in class ThreadPoolExecutor
shutdown
public void shutdown()
- Specified by:
shutdown
in interface ExecutorService
- Overrides:
shutdown
in class ThreadPoolExecutor
shutdownNow
public List<Runnable> shutdownNow()
- Specified by:
shutdownNow
in interface ExecutorService
- Overrides:
shutdownNow
in class ThreadPoolExecutor
execute
public void execute(Runnable task)
- Specified by:
execute
in interface Executor
- Overrides:
execute
in class ThreadPoolExecutor
getActiveCount
public int getActiveCount()
- Overrides:
getActiveCount
in class ThreadPoolExecutor
getCompletedTaskCount
public long getCompletedTaskCount()
- Overrides:
getCompletedTaskCount
in class ThreadPoolExecutor
getLargestPoolSize
public int getLargestPoolSize()
- Overrides:
getLargestPoolSize
in class ThreadPoolExecutor
getPoolSize
public int getPoolSize()
- Overrides:
getPoolSize
in class ThreadPoolExecutor
getTaskCount
public long getTaskCount()
- Overrides:
getTaskCount
in class ThreadPoolExecutor
isTerminating
public boolean isTerminating()
- Overrides:
isTerminating
in class ThreadPoolExecutor
prestartAllCoreThreads
public int prestartAllCoreThreads()
- Overrides:
prestartAllCoreThreads
in class ThreadPoolExecutor
prestartCoreThread
public boolean prestartCoreThread()
- Overrides:
prestartCoreThread
in class ThreadPoolExecutor
getQueue
public BlockingQueue<Runnable> getQueue()
- Overrides:
getQueue
in class ThreadPoolExecutor
purge
public void purge()
- Overrides:
purge
in class ThreadPoolExecutor
remove
public boolean remove(Runnable task)
- Overrides:
remove
in class ThreadPoolExecutor
getCorePoolSize
public int getCorePoolSize()
- Overrides:
getCorePoolSize
in class ThreadPoolExecutor
setCorePoolSize
public void setCorePoolSize(int corePoolSize)
- Overrides:
setCorePoolSize
in class ThreadPoolExecutor
Copyright © 2004-2009 Apache MINA Project. All Rights Reserved.