Package org.opensearch.threadpool

Class TestThreadPool

java.lang.Object
org.opensearch.threadpool.ThreadPool
org.opensearch.threadpool.TestThreadPool
All Implemented Interfaces:
org.opensearch.node.ReportingService<org.opensearch.threadpool.ThreadPoolInfo>, org.opensearch.threadpool.Scheduler
public class TestThreadPool
extends org.opensearch.threadpool.ThreadPool

  • Nested Class Summary

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

    org.opensearch.threadpool.ThreadPool.Info, org.opensearch.threadpool.ThreadPool.Names, org.opensearch.threadpool.ThreadPool.ThreadPoolType

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

    org.opensearch.threadpool.Scheduler.Cancellable, org.opensearch.threadpool.Scheduler.ReschedulingRunnable, org.opensearch.threadpool.Scheduler.SafeScheduledThreadPoolExecutor, org.opensearch.threadpool.Scheduler.ScheduledCancellable

  • Field Summary

    Fields inherited from class org.opensearch.threadpool.ThreadPool

    ESTIMATED_TIME_INTERVAL_SETTING, THREAD_POOL_TYPES

  • Constructor Summary

    Constructors 
    Constructor Description
    TestThreadPool​(java.lang.String name, org.opensearch.common.settings.Settings settings, org.opensearch.threadpool.ExecutorBuilder<?>... customBuilders)  
    TestThreadPool​(java.lang.String name, org.opensearch.threadpool.ExecutorBuilder<?>... customBuilders)  

  • Method Summary

    Modifier and Type Method Description
    java.util.concurrent.ExecutorService executor​(java.lang.String name)  
    void shutdown()  
    void shutdownNow()  
    void startForcingRejections()  
    void stopForcingRejections()  

    Methods inherited from class org.opensearch.threadpool.ThreadPool

    absoluteTimeInMillis, assertCurrentMethodIsNotCalledRecursively, assertNotScheduleThread, awaitTermination, builders, generic, getThreadContext, info, info, relativeTimeInMillis, relativeTimeInNanos, schedule, scheduler, scheduleUnlessShuttingDown, scheduleWithFixedDelay, searchThreadPoolSize, stats, stopCachedTimeThread, terminate, terminate

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • TestThreadPool

      public TestThreadPool​(java.lang.String name, org.opensearch.threadpool.ExecutorBuilder<?>... customBuilders)

    • TestThreadPool

      public TestThreadPool​(java.lang.String name, org.opensearch.common.settings.Settings settings, org.opensearch.threadpool.ExecutorBuilder<?>... customBuilders)

  • Method Details

    • executor

      public java.util.concurrent.ExecutorService executor​(java.lang.String name)
      Overrides:
      executor in class org.opensearch.threadpool.ThreadPool

    • startForcingRejections

      public void startForcingRejections()

    • stopForcingRejections

      public void stopForcingRejections()

    • shutdown

      public void shutdown()
      Overrides:
      shutdown in class org.opensearch.threadpool.ThreadPool

    • shutdownNow

      public void shutdownNow()
      Overrides:
      shutdownNow in class org.opensearch.threadpool.ThreadPool