org.elasticsearch.common.util.concurrent
Class EsExecutors

java.lang.Object
  org.elasticsearch.common.util.concurrent.EsExecutors

public class EsExecutors
extends Object

Method Summary

static ThreadFactory	daemonThreadFactory(Settings settings, String namePrefix)
static ThreadFactory	daemonThreadFactory(String namePrefix)
static EsThreadPoolExecutor	newBlockingExecutorService(int min, int max, long keepAliveTime, TimeUnit unit, ThreadFactory threadFactory, int capacity, long waitTime, TimeUnit waitTimeUnit)
static EsThreadPoolExecutor	newScalingExecutorService(int min, int max, long keepAliveTime, TimeUnit unit, ThreadFactory threadFactory)
static String	threadName(Settings settings, String namePrefix)

Methods inherited from class java.lang.Object

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

Method Detail

newScalingExecutorService

public static EsThreadPoolExecutor newScalingExecutorService(int min,
                                                             int max,
                                                             long keepAliveTime,
                                                             TimeUnit unit,
                                                             ThreadFactory threadFactory)

newBlockingExecutorService

public static EsThreadPoolExecutor newBlockingExecutorService(int min,
                                                              int max,
                                                              long keepAliveTime,
                                                              TimeUnit unit,
                                                              ThreadFactory threadFactory,
                                                              int capacity,
                                                              long waitTime,
                                                              TimeUnit waitTimeUnit)

threadName

public static String threadName(Settings settings,
                                String namePrefix)

daemonThreadFactory

public static ThreadFactory daemonThreadFactory(Settings settings,
                                                String namePrefix)

daemonThreadFactory

public static ThreadFactory daemonThreadFactory(String namePrefix)