public class UnorderedThreadPoolExecutor
extends java.util.concurrent.ThreadPoolExecutor
ThreadPoolExecutor
that does not maintain the order of IoEvent
s.
This means more than one event handler methods can be invoked at the same
time with mixed order. For example, let's assume that messageReceived, messageSent,
and sessionClosed events are fired.
OrderedThreadPoolExecutor
.构造器和说明 |
---|
UnorderedThreadPoolExecutor() |
UnorderedThreadPoolExecutor(int maximumPoolSize) |
UnorderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize) |
UnorderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit) |
UnorderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
IoEventQueueHandler queueHandler) |
UnorderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.ThreadFactory threadFactory) |
UnorderedThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.ThreadFactory threadFactory,
IoEventQueueHandler queueHandler) |
限定符和类型 | 方法和说明 |
---|---|
boolean |
awaitTermination(long timeout,
java.util.concurrent.TimeUnit unit) |
void |
execute(java.lang.Runnable task) |
int |
getActiveCount() |
long |
getCompletedTaskCount() |
int |
getCorePoolSize() |
int |
getLargestPoolSize() |
int |
getMaximumPoolSize() |
int |
getPoolSize() |
IoEventQueueHandler |
getQueueHandler() |
long |
getTaskCount() |
boolean |
isShutdown() |
boolean |
isTerminated() |
boolean |
isTerminating() |
int |
prestartAllCoreThreads() |
boolean |
prestartCoreThread() |
void |
purge() |
boolean |
remove(java.lang.Runnable task) |
void |
setCorePoolSize(int corePoolSize) |
void |
setMaximumPoolSize(int maximumPoolSize) |
void |
setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler handler) |
void |
shutdown() |
java.util.List<java.lang.Runnable> |
shutdownNow() |
afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, beforeExecute, finalize, getKeepAliveTime, getQueue, getRejectedExecutionHandler, getThreadFactory, setKeepAliveTime, setThreadFactory, terminated, toString
public UnorderedThreadPoolExecutor()
public UnorderedThreadPoolExecutor(int maximumPoolSize)
public UnorderedThreadPoolExecutor(int corePoolSize, int maximumPoolSize)
public UnorderedThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit)
public UnorderedThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, IoEventQueueHandler queueHandler)
public UnorderedThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.ThreadFactory threadFactory)
public UnorderedThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.ThreadFactory threadFactory, IoEventQueueHandler queueHandler)
public IoEventQueueHandler getQueueHandler()
public void setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler handler)
setRejectedExecutionHandler
在类中 java.util.concurrent.ThreadPoolExecutor
public int getMaximumPoolSize()
getMaximumPoolSize
在类中 java.util.concurrent.ThreadPoolExecutor
public void setMaximumPoolSize(int maximumPoolSize)
setMaximumPoolSize
在类中 java.util.concurrent.ThreadPoolExecutor
public boolean awaitTermination(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
awaitTermination
在接口中 java.util.concurrent.ExecutorService
awaitTermination
在类中 java.util.concurrent.ThreadPoolExecutor
java.lang.InterruptedException
public boolean isShutdown()
isShutdown
在接口中 java.util.concurrent.ExecutorService
isShutdown
在类中 java.util.concurrent.ThreadPoolExecutor
public boolean isTerminated()
isTerminated
在接口中 java.util.concurrent.ExecutorService
isTerminated
在类中 java.util.concurrent.ThreadPoolExecutor
public void shutdown()
shutdown
在接口中 java.util.concurrent.ExecutorService
shutdown
在类中 java.util.concurrent.ThreadPoolExecutor
public java.util.List<java.lang.Runnable> shutdownNow()
shutdownNow
在接口中 java.util.concurrent.ExecutorService
shutdownNow
在类中 java.util.concurrent.ThreadPoolExecutor
public void execute(java.lang.Runnable task)
execute
在接口中 java.util.concurrent.Executor
execute
在类中 java.util.concurrent.ThreadPoolExecutor
public int getActiveCount()
getActiveCount
在类中 java.util.concurrent.ThreadPoolExecutor
public long getCompletedTaskCount()
getCompletedTaskCount
在类中 java.util.concurrent.ThreadPoolExecutor
public int getLargestPoolSize()
getLargestPoolSize
在类中 java.util.concurrent.ThreadPoolExecutor
public int getPoolSize()
getPoolSize
在类中 java.util.concurrent.ThreadPoolExecutor
public long getTaskCount()
getTaskCount
在类中 java.util.concurrent.ThreadPoolExecutor
public boolean isTerminating()
isTerminating
在类中 java.util.concurrent.ThreadPoolExecutor
public int prestartAllCoreThreads()
prestartAllCoreThreads
在类中 java.util.concurrent.ThreadPoolExecutor
public boolean prestartCoreThread()
prestartCoreThread
在类中 java.util.concurrent.ThreadPoolExecutor
public void purge()
purge
在类中 java.util.concurrent.ThreadPoolExecutor
public boolean remove(java.lang.Runnable task)
remove
在类中 java.util.concurrent.ThreadPoolExecutor
public int getCorePoolSize()
getCorePoolSize
在类中 java.util.concurrent.ThreadPoolExecutor
public void setCorePoolSize(int corePoolSize)
setCorePoolSize
在类中 java.util.concurrent.ThreadPoolExecutor