com.levigo.util.concurrent.tasks
Class QueuedAndActiveTaskThreadPoolExecutor

java.lang.Object
  java.util.concurrent.AbstractExecutorService
      java.util.concurrent.ThreadPoolExecutor
          com.levigo.util.concurrent.tasks.QueuedAndActiveTaskThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService

public class QueuedAndActiveTaskThreadPoolExecutor
extends ThreadPoolExecutor

An enhancement of the ThreadPoolExecutor which provides access to the queued and active Tasks and their TaskWrappers.

Author:

Carolin Koehler

Nested Class Summary

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

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

Constructor Summary

QueuedAndActiveTaskThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)

Method Summary

protected void	afterExecute(Runnable r, Throwable t)
void	clearQueuedTaskWrappers()
void	execute(Runnable r)

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

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

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

QueuedAndActiveTaskThreadPoolExecutor

public QueuedAndActiveTaskThreadPoolExecutor(int corePoolSize,
                                             int maximumPoolSize,
                                             long keepAliveTime,
                                             TimeUnit unit,
                                             BlockingQueue<Runnable> workQueue,
                                             ThreadFactory threadFactory)

Method Detail

afterExecute

protected void afterExecute(Runnable r,
                            Throwable t)

Overrides:

afterExecute in class ThreadPoolExecutor

execute

public void execute(Runnable r)

Specified by:

execute in interface Executor

Overrides:

execute in class ThreadPoolExecutor

clearQueuedTaskWrappers

public void clearQueuedTaskWrappers()