Module org.elasticsearch.server

Package org.elasticsearch.common.util.concurrent

Class PrioritizedEsThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor

org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService

public class PrioritizedEsThreadPoolExecutor
extends EsThreadPoolExecutor

A prioritizing executor which uses a priority queue as a work queue. The jobs that will be submitted will be treated as PrioritizedRunnable and/or PrioritizedCallable, those tasks that are not instances of these two will be wrapped and assign a default Priority.NORMAL priority.

Note, if two tasks have the same priority, the first to arrive will be executed first (FIFO style).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PrioritizedEsThreadPoolExecutor.Pending
static interface	PrioritizedEsThreadPoolExecutor.StarvationWatcher	We expect the work queue to be empty fairly frequently; if the queue remains nonempty for sufficiently long then there's a risk that some lower-priority tasks are being starved of access to the executor.

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

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

Constructor Summary

Constructors

Constructor	Description
PrioritizedEsThreadPoolExecutor(String name, int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, ThreadFactory threadFactory, ThreadContext contextHolder, ScheduledExecutorService timer, PrioritizedEsThreadPoolExecutor.StarvationWatcher starvationWatcher)

Method Summary

Modifier and Type	Method	Description
protected void	afterExecute(Runnable r, Throwable t)
protected void	beforeExecute(Thread t, Runnable r)
void	execute(Runnable command, TimeValue timeout, Runnable timeoutCallback)
TimeValue	getMaxTaskWaitTime()	Returns the waiting time of the first task in the queue
int	getNumberOfPendingTasks()
PrioritizedEsThreadPoolExecutor.Pending[]	getPending()
protected <T> RunnableFuture<T>	newTaskFor(Runnable runnable, T value)
protected <T> RunnableFuture<T>	newTaskFor(Callable<T> callable)
protected Runnable	unwrap(Runnable runnable)
protected Runnable	wrapRunnable(Runnable command)

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

appendThreadPoolExecutorDetails, execute, getTasks, toString

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

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

Methods inherited from class java.lang.Object

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

Constructor Details

PrioritizedEsThreadPoolExecutor

public PrioritizedEsThreadPoolExecutor(String name,
 int corePoolSize,
 int maximumPoolSize,
 long keepAliveTime,
 TimeUnit unit,
 ThreadFactory threadFactory,
 ThreadContext contextHolder,
 ScheduledExecutorService timer,
 PrioritizedEsThreadPoolExecutor.StarvationWatcher starvationWatcher)

Method Details

getPending

public PrioritizedEsThreadPoolExecutor.Pending[] getPending()

getNumberOfPendingTasks

public int getNumberOfPendingTasks()

getMaxTaskWaitTime

public TimeValue getMaxTaskWaitTime()

Returns the waiting time of the first task in the queue

beforeExecute

protected void beforeExecute(Thread t,
 Runnable r)

Overrides:

beforeExecute in class ThreadPoolExecutor

afterExecute

protected void afterExecute(Runnable r,
 Throwable t)

Overrides:

afterExecute in class EsThreadPoolExecutor

execute

public void execute(Runnable command,
 TimeValue timeout,
 Runnable timeoutCallback)

wrapRunnable

protected Runnable wrapRunnable(Runnable command)

Overrides:

wrapRunnable in class EsThreadPoolExecutor

unwrap

protected Runnable unwrap(Runnable runnable)

Overrides:

unwrap in class EsThreadPoolExecutor

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Runnable runnable,
 T value)

Overrides:

newTaskFor in class AbstractExecutorService

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable)

Overrides:

newTaskFor in class AbstractExecutorService