org.apache.hadoop.hbase.executor

Class ExecutorService.TrackingThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.apache.hadoop.hbase.executor.ExecutorService.TrackingThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService

Enclosing class:

ExecutorService

static class ExecutorService.TrackingThreadPoolExecutor
extends ThreadPoolExecutor

A subclass of ThreadPoolExecutor that keeps track of the Runnables that are executing at any given point in time.

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
private ConcurrentMap<Thread,Runnable>	running

Constructor Summary

Constructors

Constructor and Description
TrackingThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)

Method Summary

Modifier and Type	Method and Description
protected void	afterExecute(Runnable r, Throwable t)
protected void	beforeExecute(Thread t, Runnable r)
ConcurrentMap<Thread,Runnable>	getRunningTasks()

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, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Field Detail

running

private ConcurrentMap<Thread,Runnable> running

Constructor Detail

TrackingThreadPoolExecutor

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

Method Detail

afterExecute

protected void afterExecute(Runnable r,
                            Throwable t)

Overrides:

afterExecute in class ThreadPoolExecutor

beforeExecute

protected void beforeExecute(Thread t,
                             Runnable r)

Overrides:

beforeExecute in class ThreadPoolExecutor

getRunningTasks

public ConcurrentMap<Thread,Runnable> getRunningTasks()

Returns:

a map of the threads currently running tasks inside this executor. Each key is an active thread, and the value is the task that is currently running. Note that this is not a stable snapshot of the map.