Package org.elasticsearch.common.util.concurrent

Class QueueResizingEsThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor

org.elasticsearch.common.util.concurrent.QueueResizingEsThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService

public final class QueueResizingEsThreadPoolExecutor
extends EsThreadPoolExecutor

An extension to thread pool executor, which automatically adjusts the queue size of the ResizableBlockingQueue according to Little's Law.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor

EsThreadPoolExecutor.ShutdownListener

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	Description
static double	EWMA_ALPHA

Method Summary

Modifier and Type	Method	Description
protected void	afterExecute(Runnable r, Throwable t)
protected void	appendThreadPoolExecutorDetails(StringBuilder sb)	Append details about this thread pool to the specified StringBuilder.
int	getCurrentQueueSize()	Returns the current queue size (operations that are queued)
double	getTaskExecutionEWMA()	Returns the exponentially weighted moving average of the task execution time
protected Runnable	unwrap(Runnable runnable)
protected Runnable	wrapRunnable(Runnable command)

Methods inherited from class org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor

execute, getTasks, terminated, toString

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

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 Details

EWMA_ALPHA

public static double EWMA_ALPHA

Method Details

wrapRunnable

protected Runnable wrapRunnable(Runnable command)

Overrides:

wrapRunnable in class EsThreadPoolExecutor

unwrap

protected Runnable unwrap(Runnable runnable)

Overrides:

unwrap in class EsThreadPoolExecutor

getTaskExecutionEWMA

public double getTaskExecutionEWMA()

Returns the exponentially weighted moving average of the task execution time

getCurrentQueueSize

public int getCurrentQueueSize()

Returns the current queue size (operations that are queued)

afterExecute

protected void afterExecute(Runnable r,
 Throwable t)

Overrides:

afterExecute in class EsThreadPoolExecutor

appendThreadPoolExecutorDetails

protected void appendThreadPoolExecutorDetails(StringBuilder sb)

Description copied from class: EsThreadPoolExecutor

Append details about this thread pool to the specified StringBuilder. All details should be appended as key/value pairs in the form "%s = %s, "

Overrides:

appendThreadPoolExecutorDetails in class EsThreadPoolExecutor

Parameters:

sb - the StringBuilder to append to