Package org.elasticsearch.common.util.concurrent

Class DeterministicTaskQueue.DeterministicThreadPool

java.lang.Object

org.elasticsearch.threadpool.ThreadPool

org.elasticsearch.common.util.concurrent.DeterministicTaskQueue.DeterministicThreadPool

All Implemented Interfaces:

TimeProvider, ReportingService<ThreadPoolInfo>, Scheduler

Enclosing class:

DeterministicTaskQueue

protected class DeterministicTaskQueue.DeterministicThreadPool
extends ThreadPool

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.threadpool.ThreadPool

ThreadPool.Info, ThreadPool.Names, ThreadPool.ThreadPoolType

Nested classes/interfaces inherited from interface org.elasticsearch.threadpool.Scheduler

Scheduler.Cancellable, Scheduler.ReschedulingRunnable, Scheduler.SafeScheduledThreadPoolExecutor, Scheduler.ScheduledCancellable

Field Summary

Fields

Modifier and Type	Field	Description
protected final ExecutorService	forkingExecutor
protected final Function<Runnable,Runnable>	runnableWrapper

Fields inherited from class org.elasticsearch.threadpool.ThreadPool

DEFAULT_INDEX_AUTOSCALING_EWMA_ALPHA, ESTIMATED_TIME_INTERVAL_SETTING, LATE_TIME_INTERVAL_WARN_THRESHOLD_SETTING, searchAutoscalingEWMA, SLOW_SCHEDULER_TASK_WARN_THRESHOLD_SETTING, THREAD_POOL_METRIC_NAME_ACTIVE, THREAD_POOL_METRIC_NAME_COMPLETED, THREAD_POOL_METRIC_NAME_CURRENT, THREAD_POOL_METRIC_NAME_LARGEST, THREAD_POOL_METRIC_NAME_QUEUE, THREAD_POOL_METRIC_NAME_QUEUE_TIME, THREAD_POOL_METRIC_NAME_REJECTED, THREAD_POOL_METRIC_NAME_UTILIZATION, THREAD_POOL_METRIC_PREFIX, THREAD_POOL_TYPES, WRITE_THREAD_POOLS_EWMA_ALPHA_SETTING

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DeterministicThreadPool(Function<Runnable,Runnable> runnableWrapper)

Method Summary

Modifier and Type	Method	Description
long	absoluteTimeInMillis()
boolean	awaitTermination(long timeout, TimeUnit unit)
ExecutorService	executor(String name)
ExecutorService	generic()
ThreadPoolInfo	info()
ThreadPool.Info	info(String name)
long	rawRelativeTimeInMillis()
long	relativeTimeInMillis()
long	relativeTimeInNanos()
Scheduler.ScheduledCancellable	schedule(Runnable command, org.elasticsearch.core.TimeValue delay, Executor executor)
ScheduledExecutorService	scheduler()
void	shutdown()
void	shutdownNow()
ThreadPoolStats	stats()

Methods inherited from class org.elasticsearch.threadpool.ThreadPool

assertCurrentMethodIsNotCalledRecursively, assertCurrentThreadPool, assertInSystemContext, assertNotScheduleThread, builders, getMaxSnapshotThreadPoolSize, getThreadContext, oneEighthAllocatedProcessors, relativeTimeInMillisSupplier, scheduleUnlessShuttingDown, scheduleWithFixedDelay, searchOrGetThreadPoolSize, stopCachedTimeThread, terminate, terminate

Methods inherited from class java.lang.Object

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

Field Details

forkingExecutor

protected final ExecutorService forkingExecutor

runnableWrapper

protected final Function<Runnable,Runnable> runnableWrapper

Constructor Details

DeterministicThreadPool

protected DeterministicThreadPool(Function<Runnable,Runnable> runnableWrapper)

Method Details

relativeTimeInNanos

public long relativeTimeInNanos()

Specified by:

relativeTimeInNanos in interface TimeProvider

Overrides:

relativeTimeInNanos in class ThreadPool

relativeTimeInMillis

public long relativeTimeInMillis()

Specified by:

relativeTimeInMillis in interface TimeProvider

Overrides:

relativeTimeInMillis in class ThreadPool

rawRelativeTimeInMillis

public long rawRelativeTimeInMillis()

Specified by:

rawRelativeTimeInMillis in interface TimeProvider

Overrides:

rawRelativeTimeInMillis in class ThreadPool

absoluteTimeInMillis

public long absoluteTimeInMillis()

Specified by:

absoluteTimeInMillis in interface TimeProvider

Overrides:

absoluteTimeInMillis in class ThreadPool

info

public ThreadPoolInfo info()

Specified by:

info in interface ReportingService<ThreadPoolInfo>

Overrides:

info in class ThreadPool

info

public ThreadPool.Info info(String name)

Overrides:

info in class ThreadPool

stats

public ThreadPoolStats stats()

Overrides:

stats in class ThreadPool

generic

public ExecutorService generic()

Overrides:

generic in class ThreadPool

executor

public ExecutorService executor(String name)

Overrides:

executor in class ThreadPool

schedule

public Scheduler.ScheduledCancellable schedule(Runnable command,
 org.elasticsearch.core.TimeValue delay,
 Executor executor)

Specified by:

schedule in interface Scheduler

Overrides:

schedule in class ThreadPool

shutdown

public void shutdown()

Overrides:

shutdown in class ThreadPool

shutdownNow

public void shutdownNow()

Overrides:

shutdownNow in class ThreadPool

awaitTermination

public boolean awaitTermination(long timeout,
 TimeUnit unit)

Overrides:

awaitTermination in class ThreadPool

scheduler

public ScheduledExecutorService scheduler()

Overrides:

scheduler in class ThreadPool