Package org.opensearch.cluster.coordination

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:
java.util.concurrent.Executor, java.util.concurrent.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

    java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

  • Constructor Summary

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

  • Method Summary

    Modifier and Type Method Description
    protected void afterExecute​(java.lang.Runnable r, java.lang.Throwable t)  
    boolean awaitTermination​(long timeout, java.util.concurrent.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, 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

  • Constructor Details

  • Method Details

    • afterExecute

      protected void afterExecute​(java.lang.Runnable r, java.lang.Throwable t)
      Overrides:
      afterExecute in class org.opensearch.common.util.concurrent.PrioritizedOpenSearchThreadPoolExecutor

    • awaitTermination

      public boolean awaitTermination​(long timeout, java.util.concurrent.TimeUnit unit)
      Specified by:
      awaitTermination in interface java.util.concurrent.ExecutorService
      Overrides:
      awaitTermination in class java.util.concurrent.ThreadPoolExecutor