co.paralleluniverse.common.concurrent

Class OrderedThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

co.paralleluniverse.common.concurrent.OrderedThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService

public abstract class OrderedThreadPoolExecutor
extends ThreadPoolExecutor

Adapted from Netty's org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor

Nested Class Summary

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

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

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<Object,Executor>	childExecutors

Constructor Summary

Constructors

Constructor and Description
OrderedThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, int maxQueueSize)
OrderedThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, int maxQueueSize, RejectedExecutionHandler handler)
OrderedThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, int maxQueueSize, ThreadFactory threadFactory)
OrderedThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, int maxQueueSize, ThreadFactory threadFactory, RejectedExecutionHandler handler)

Method Summary

Methods

Modifier and Type	Method and Description
void	execute(Runnable task)
protected Executor	getChildExecutor(Runnable task)
protected abstract Object	getChildExecutorKey(Runnable task)
protected boolean	removeChildExecutor(Object key)

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, 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

Field Detail

childExecutors

protected final ConcurrentMap<Object,Executor> childExecutors

Constructor Detail

OrderedThreadPoolExecutor

public OrderedThreadPoolExecutor(int corePoolSize,
                         int maximumPoolSize,
                         long keepAliveTime,
                         TimeUnit unit,
                         int maxQueueSize,
                         ThreadFactory threadFactory,
                         RejectedExecutionHandler handler)

OrderedThreadPoolExecutor

public OrderedThreadPoolExecutor(int corePoolSize,
                         int maximumPoolSize,
                         long keepAliveTime,
                         TimeUnit unit,
                         int maxQueueSize,
                         RejectedExecutionHandler handler)

OrderedThreadPoolExecutor

public OrderedThreadPoolExecutor(int corePoolSize,
                         int maximumPoolSize,
                         long keepAliveTime,
                         TimeUnit unit,
                         int maxQueueSize,
                         ThreadFactory threadFactory)

OrderedThreadPoolExecutor

public OrderedThreadPoolExecutor(int corePoolSize,
                         int maximumPoolSize,
                         long keepAliveTime,
                         TimeUnit unit,
                         int maxQueueSize)

Method Detail

execute

public void execute(Runnable task)

Specified by:

execute in interface Executor

Overrides:

execute in class ThreadPoolExecutor

getChildExecutorKey

protected abstract Object getChildExecutorKey(Runnable task)

removeChildExecutor

protected boolean removeChildExecutor(Object key)

getChildExecutor

protected Executor getChildExecutor(Runnable task)