Class MockSinglePrioritizingExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.opensearch.common.util.concurrent.OpenSearchThreadPoolExecutor

org.opensearch.common.util.concurrent.PrioritizedOpenSearchThreadPoolExecutor

org.opensearch.cluster.coordination.MockSinglePrioritizingExecutor

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService

public class MockSinglePrioritizingExecutor
extends org.opensearch.common.util.concurrent.PrioritizedOpenSearchThreadPoolExecutor

Mock single threaded PrioritizedOpenSearchThreadPoolExecutor based on DeterministicTaskQueue, simulating the behaviour of an executor returned by OpenSearchExecutors.newSinglePrioritizing(java.lang.String, java.util.concurrent.ThreadFactory, org.opensearch.common.util.concurrent.ThreadContext, java.util.concurrent.ScheduledExecutorService).

Nested Class Summary

Nested classes/interfaces inherited from class org.opensearch.common.util.concurrent.PrioritizedOpenSearchThreadPoolExecutor

org.opensearch.common.util.concurrent.PrioritizedOpenSearchThreadPoolExecutor.Pending

Nested classes/interfaces inherited from class org.opensearch.common.util.concurrent.OpenSearchThreadPoolExecutor

org.opensearch.common.util.concurrent.OpenSearchThreadPoolExecutor.ShutdownListener

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

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

Constructor Summary

Constructors

Constructor	Description
MockSinglePrioritizingExecutor(String name, DeterministicTaskQueue deterministicTaskQueue, org.opensearch.threadpool.ThreadPool threadPool)

Method Summary

Modifier and Type	Method	Description
protected void	afterExecute(Runnable r, Throwable t)
boolean	awaitTermination(long timeout, TimeUnit unit)

Methods inherited from class org.opensearch.common.util.concurrent.PrioritizedOpenSearchThreadPoolExecutor

beforeExecute, execute, getMaxTaskWaitTime, getNumberOfPendingTasks, getPending, newTaskFor, newTaskFor, unwrap, wrapRunnable

Methods inherited from class org.opensearch.common.util.concurrent.OpenSearchThreadPoolExecutor

appendThreadPoolExecutorDetails, execute, getPoolWaitTimeNanos, getTasks, terminated, toString

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

close

Constructor Details

MockSinglePrioritizingExecutor

public MockSinglePrioritizingExecutor(String name,
 DeterministicTaskQueue deterministicTaskQueue,
 org.opensearch.threadpool.ThreadPool threadPool)

Method Details

afterExecute

protected void afterExecute(Runnable r,
 Throwable t)

Overrides:

afterExecute in class org.opensearch.common.util.concurrent.PrioritizedOpenSearchThreadPoolExecutor

awaitTermination

public boolean awaitTermination(long timeout,
 TimeUnit unit)

Specified by:

awaitTermination in interface ExecutorService

Overrides:

awaitTermination in class ThreadPoolExecutor