Package org.elasticsearch.common.util.concurrent

Class EsExecutors

java.lang.Object
org.elasticsearch.common.util.concurrent.EsExecutors
public class EsExecutors
extends java.lang.Object

  • Field Summary

    Fields 
    Modifier and Type Field Description
    static Setting<java.lang.Integer> NODE_PROCESSORS_SETTING
    Setting to manually set the number of available processors.
    static Setting<java.lang.Integer> PROCESSORS_SETTING
    Setting to manually set the number of available processors.

  • Method Summary

    Modifier and Type Method Description
    static java.util.concurrent.ThreadFactory daemonThreadFactory​(java.lang.String namePrefix)  
    static java.util.concurrent.ThreadFactory daemonThreadFactory​(java.lang.String nodeName, java.lang.String namePrefix)  
    static java.util.concurrent.ThreadFactory daemonThreadFactory​(Settings settings, java.lang.String namePrefix)  
    static java.util.concurrent.ThreadFactory daemonThreadFactory​(Settings settings, java.lang.String... names)  
    static EsThreadPoolExecutor newAutoQueueFixed​(java.lang.String name, int size, int initialQueueCapacity, int minQueueSize, int maxQueueSize, int frameSize, TimeValue targetedResponseTime, java.util.concurrent.ThreadFactory threadFactory, ThreadContext contextHolder)
    Return a new executor that will automatically adjust the queue size based on queue throughput.
    static java.util.concurrent.ExecutorService newDirectExecutorService()
    Returns an ExecutorService that executes submitted tasks on the current thread.
    static EsThreadPoolExecutor newFixed​(java.lang.String name, int size, int queueCapacity, java.util.concurrent.ThreadFactory threadFactory, ThreadContext contextHolder)  
    static EsThreadPoolExecutor newScaling​(java.lang.String name, int min, int max, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.ThreadFactory threadFactory, ThreadContext contextHolder)  
    static PrioritizedEsThreadPoolExecutor newSinglePrioritizing​(java.lang.String name, java.util.concurrent.ThreadFactory threadFactory, ThreadContext contextHolder, java.util.concurrent.ScheduledExecutorService timer)  
    static int numberOfProcessors​(Settings settings)
    Returns the number of available processors.
    static java.lang.Throwable rethrowErrors​(java.lang.Runnable runnable)
    Checks if the runnable arose from asynchronous submission of a task to an executor.
    static java.lang.String threadName​(java.lang.String nodeName, java.lang.String namePrefix)  
    static java.lang.String threadName​(Settings settings, java.lang.String namePrefix)  
    static java.lang.String threadName​(Settings settings, java.lang.String... names)  

    Methods inherited from class java.lang.Object

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

  • Field Details

    • PROCESSORS_SETTING

      public static final Setting<java.lang.Integer> PROCESSORS_SETTING
      Setting to manually set the number of available processors. This setting is used to adjust thread pool sizes per node.

    • NODE_PROCESSORS_SETTING

      public static final Setting<java.lang.Integer> NODE_PROCESSORS_SETTING
      Setting to manually set the number of available processors. This setting is used to adjust thread pool sizes per node.

  • Method Details

    • numberOfProcessors

      public static int numberOfProcessors​(Settings settings)
      Returns the number of available processors. Defaults to Runtime.availableProcessors() but can be overridden by passing a Settings instance with the key "processors" set to the desired value.
      Parameters:
      settings - a Settings instance from which to derive the available processors
      Returns:
      the number of available processors

    • newSinglePrioritizing

      public static PrioritizedEsThreadPoolExecutor newSinglePrioritizing​(java.lang.String name, java.util.concurrent.ThreadFactory threadFactory, ThreadContext contextHolder, java.util.concurrent.ScheduledExecutorService timer)

    • newScaling

      public static EsThreadPoolExecutor newScaling​(java.lang.String name, int min, int max, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.ThreadFactory threadFactory, ThreadContext contextHolder)

    • newFixed

      public static EsThreadPoolExecutor newFixed​(java.lang.String name, int size, int queueCapacity, java.util.concurrent.ThreadFactory threadFactory, ThreadContext contextHolder)

    • newAutoQueueFixed

      public static EsThreadPoolExecutor newAutoQueueFixed​(java.lang.String name, int size, int initialQueueCapacity, int minQueueSize, int maxQueueSize, int frameSize, TimeValue targetedResponseTime, java.util.concurrent.ThreadFactory threadFactory, ThreadContext contextHolder)
      Return a new executor that will automatically adjust the queue size based on queue throughput.
      Parameters:
      size - number of fixed threads to use for executing tasks
      initialQueueCapacity - initial size of the executor queue
      minQueueSize - minimum queue size that the queue can be adjusted to
      maxQueueSize - maximum queue size that the queue can be adjusted to
      frameSize - number of tasks during which stats are collected before adjusting queue size

    • rethrowErrors

      public static java.lang.Throwable rethrowErrors​(java.lang.Runnable runnable)
      Checks if the runnable arose from asynchronous submission of a task to an executor. If an uncaught exception was thrown during the execution of this task, we need to inspect this runnable and see if it is an error that should be propagated to the uncaught exception handler.
      Parameters:
      runnable - the runnable to inspect, should be a RunnableFuture
      Returns:
      non fatal exception or null if no exception.

    • newDirectExecutorService

      public static java.util.concurrent.ExecutorService newDirectExecutorService()
      Returns an ExecutorService that executes submitted tasks on the current thread. This executor service does not support being shutdown.
      Returns:
      an ExecutorService that executes submitted tasks on the current thread

    • threadName

      public static java.lang.String threadName​(Settings settings, java.lang.String... names)

    • threadName

      public static java.lang.String threadName​(Settings settings, java.lang.String namePrefix)

    • threadName

      public static java.lang.String threadName​(java.lang.String nodeName, java.lang.String namePrefix)

    • daemonThreadFactory

      public static java.util.concurrent.ThreadFactory daemonThreadFactory​(Settings settings, java.lang.String namePrefix)

    • daemonThreadFactory

      public static java.util.concurrent.ThreadFactory daemonThreadFactory​(java.lang.String nodeName, java.lang.String namePrefix)

    • daemonThreadFactory

      public static java.util.concurrent.ThreadFactory daemonThreadFactory​(Settings settings, java.lang.String... names)

    • daemonThreadFactory

      public static java.util.concurrent.ThreadFactory daemonThreadFactory​(java.lang.String namePrefix)