Class TestThreadPool

java.lang.Object
org.opensearch.threadpool.ThreadPool
org.opensearch.threadpool.TestThreadPool
All Implemented Interfaces:
org.opensearch.core.service.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

    CLUSTER_THREAD_POOL_SIZE_SETTING, ESTIMATED_TIME_INTERVAL_SETTING, THREAD_POOL_TYPES

  • Constructor Summary

    Constructors
    Constructor
    Description
    TestThreadPool(String name, AtomicReference<org.opensearch.threadpool.RunnableTaskExecutionListener> runnableTaskListener, org.opensearch.threadpool.ExecutorBuilder<?>... customBuilders)
     
    TestThreadPool(String name, org.opensearch.common.settings.Settings settings, AtomicReference<org.opensearch.threadpool.RunnableTaskExecutionListener> runnableTaskListener, org.opensearch.threadpool.ExecutorBuilder<?>... customBuilders)
     
    TestThreadPool(String name, org.opensearch.common.settings.Settings settings, org.opensearch.threadpool.ExecutorBuilder<?>... customBuilders)
     
    TestThreadPool(String name, org.opensearch.threadpool.ExecutorBuilder<?>... customBuilders)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    ExecutorService
    executor(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, preciseRelativeTimeInNanos, registerClusterSettingsListeners, relativeTimeInMillis, relativeTimeInNanos, schedule, scheduler, scheduleUnlessShuttingDown, scheduleWithFixedDelay, searchThreadPoolSize, setThreadPool, 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(String name, AtomicReference<org.opensearch.threadpool.RunnableTaskExecutionListener> runnableTaskListener, org.opensearch.threadpool.ExecutorBuilder<?>... customBuilders)

    • TestThreadPool

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

    • TestThreadPool

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

    • TestThreadPool

      public TestThreadPool(String name, org.opensearch.common.settings.Settings settings, AtomicReference<org.opensearch.threadpool.RunnableTaskExecutionListener> runnableTaskListener, org.opensearch.threadpool.ExecutorBuilder<?>... customBuilders)

  • Method Details

    • executor

      public ExecutorService executor(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