acs.benchmark.util

Class ConcurrentComponentAccessUtil.BenchmarkTreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

acs.benchmark.util.ConcurrentComponentAccessUtil.BenchmarkTreadPoolExecutor

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService

Enclosing class:

ConcurrentComponentAccessUtil

public class ConcurrentComponentAccessUtil.BenchmarkTreadPoolExecutor
extends java.util.concurrent.ThreadPoolExecutor

The thread pool to add statistics to the FutureTask.

Nested Class Summary

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

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor and Description
BenchmarkTreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method and Description
protected void	afterExecute(java.lang.Runnable r, java.lang.Throwable t) Set the end execution time
protected void	beforeExecute(java.lang.Thread t, java.lang.Runnable r) Set the start execution time
protected <T> java.util.concurrent.RunnableFuture<T>	newTaskFor(java.util.concurrent.Callable<T> callable) The FutureTask is of type ConcurrentComponentAccessUtil.InstrumentedFutureTask
protected <T> java.util.concurrent.RunnableFuture<T>	newTaskFor(java.lang.Runnable runnable, T value) The FutureTask is of type ConcurrentComponentAccessUtil.InstrumentedFutureTask

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, execute, 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, submit, submit, submit

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

BenchmarkTreadPoolExecutor

public BenchmarkTreadPoolExecutor(int corePoolSize,
                                  int maximumPoolSize,
                                  long keepAliveTime,
                                  java.util.concurrent.TimeUnit unit,
                                  java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                  java.util.concurrent.ThreadFactory threadFactory)

Method Detail

newTaskFor

protected <T> java.util.concurrent.RunnableFuture<T> newTaskFor(java.lang.Runnable runnable,
                                                                T value)

The FutureTask is of type ConcurrentComponentAccessUtil.InstrumentedFutureTask

Overrides:

newTaskFor in class java.util.concurrent.AbstractExecutorService

newTaskFor

protected <T> java.util.concurrent.RunnableFuture<T> newTaskFor(java.util.concurrent.Callable<T> callable)

The FutureTask is of type ConcurrentComponentAccessUtil.InstrumentedFutureTask

Overrides:

newTaskFor in class java.util.concurrent.AbstractExecutorService

beforeExecute

protected void beforeExecute(java.lang.Thread t,
                             java.lang.Runnable r)

Set the start execution time

Overrides:

beforeExecute in class java.util.concurrent.ThreadPoolExecutor

afterExecute

protected void afterExecute(java.lang.Runnable r,
                            java.lang.Throwable t)

Set the end execution time

Overrides:

afterExecute in class java.util.concurrent.ThreadPoolExecutor