org.elasticsearch.threadpool
Class ThreadPool

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.threadpool.ThreadPool

public class ThreadPool
extends AbstractComponent

Nested Class Summary

static class	ThreadPool.Info
static class	ThreadPool.Names

Field Summary

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

ThreadPool()

ThreadPool(Settings settings)

Method Summary

boolean	awaitTermination(long timeout, TimeUnit unit)
long	estimatedTimeInMillis()
Executor	executor(String name)
Executor	generic()
ThreadPoolInfo	info()
ScheduledFuture<?>	schedule(TimeValue delay, String name, Runnable command)
ScheduledExecutorService	scheduler()
ScheduledFuture<?>	scheduleWithFixedDelay(Runnable command, TimeValue interval)
void	shutdown()
void	shutdownNow()
ThreadPoolStats	stats()

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadPool

public ThreadPool()

ThreadPool

@Inject
public ThreadPool(Settings settings)

Method Detail

estimatedTimeInMillis

public long estimatedTimeInMillis()

info

public ThreadPoolInfo info()

stats

public ThreadPoolStats stats()

generic

public Executor generic()

executor

public Executor executor(String name)

scheduler

public ScheduledExecutorService scheduler()

scheduleWithFixedDelay

public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
                                                 TimeValue interval)

schedule

public ScheduledFuture<?> schedule(TimeValue delay,
                                   String name,
                                   Runnable command)

shutdown

public void shutdown()

shutdownNow

public void shutdownNow()

awaitTermination

public boolean awaitTermination(long timeout,
                                TimeUnit unit)
                         throws InterruptedException

Throws:

InterruptedException