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
-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.threadpool.ThreadPool
ThreadPool.Info, ThreadPool.Names, ThreadPool.ThreadPoolTypeNested classes/interfaces inherited from interface org.elasticsearch.threadpool.Scheduler
Scheduler.Cancellable, Scheduler.ReschedulingRunnable, Scheduler.SafeScheduledThreadPoolExecutor, Scheduler.ScheduledCancellable -
Field Summary
FieldsFields 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
ConstructorsModifierConstructorDescriptionprotectedDeterministicThreadPool(Function<Runnable, Runnable> runnableWrapper) -
Method Summary
Methods inherited from class org.elasticsearch.threadpool.ThreadPool
assertCurrentMethodIsNotCalledRecursively, assertCurrentThreadPool, assertInSystemContext, assertNotScheduleThread, builders, getMaxSnapshotThreadPoolSize, getThreadContext, oneEighthAllocatedProcessors, relativeTimeInMillisSupplier, scheduleUnlessShuttingDown, scheduleWithFixedDelay, searchOrGetThreadPoolSize, stopCachedTimeThread, terminate, terminate
-
Field Details
-
forkingExecutor
-
runnableWrapper
-
-
Constructor Details
-
DeterministicThreadPool
-
-
Method Details
-
relativeTimeInNanos
public long relativeTimeInNanos()- Specified by:
relativeTimeInNanosin interfaceTimeProvider- Overrides:
relativeTimeInNanosin classThreadPool
-
relativeTimeInMillis
public long relativeTimeInMillis()- Specified by:
relativeTimeInMillisin interfaceTimeProvider- Overrides:
relativeTimeInMillisin classThreadPool
-
rawRelativeTimeInMillis
public long rawRelativeTimeInMillis()- Specified by:
rawRelativeTimeInMillisin interfaceTimeProvider- Overrides:
rawRelativeTimeInMillisin classThreadPool
-
absoluteTimeInMillis
public long absoluteTimeInMillis()- Specified by:
absoluteTimeInMillisin interfaceTimeProvider- Overrides:
absoluteTimeInMillisin classThreadPool
-
info
- Specified by:
infoin interfaceReportingService<ThreadPoolInfo>- Overrides:
infoin classThreadPool
-
info
- Overrides:
infoin classThreadPool
-
stats
- Overrides:
statsin classThreadPool
-
generic
- Overrides:
genericin classThreadPool
-
executor
- Overrides:
executorin classThreadPool
-
schedule
public Scheduler.ScheduledCancellable schedule(Runnable command, org.elasticsearch.core.TimeValue delay, Executor executor) - Specified by:
schedulein interfaceScheduler- Overrides:
schedulein classThreadPool
-
shutdown
public void shutdown()- Overrides:
shutdownin classThreadPool
-
shutdownNow
public void shutdownNow()- Overrides:
shutdownNowin classThreadPool
-
awaitTermination
- Overrides:
awaitTerminationin classThreadPool
-
scheduler
- Overrides:
schedulerin classThreadPool
-