public class ThreadPool extends AbstractComponent
Modifier and Type | Class and Description |
---|---|
static class |
ThreadPool.Info |
static class |
ThreadPool.Names |
Modifier and Type | Field and Description |
---|---|
static String |
THREADPOOL_GROUP |
componentSettings, logger, settings
Constructor and Description |
---|
ThreadPool(Settings settings,
NodeSettingsService nodeSettingsService) |
ThreadPool(String name) |
Modifier and Type | Method and Description |
---|---|
boolean |
awaitTermination(long timeout,
TimeUnit unit) |
long |
estimatedTimeInMillis() |
org.apache.lucene.util.Counter |
estimatedTimeInMillisCounter() |
Executor |
executor(String name) |
Executor |
generic() |
ThreadPoolInfo |
info() |
ThreadPool.Info |
info(String name) |
ScheduledFuture<?> |
schedule(TimeValue delay,
String name,
Runnable command) |
ScheduledExecutorService |
scheduler() |
ScheduledFuture<?> |
scheduleWithFixedDelay(Runnable command,
TimeValue interval) |
void |
shutdown() |
void |
shutdownNow() |
ThreadPoolStats |
stats() |
static boolean |
terminate(ExecutorService service,
long timeout,
TimeUnit timeUnit)
Returns
true if the given service was terminated successfully. |
static boolean |
terminate(ThreadPool pool,
long timeout,
TimeUnit timeUnit)
Returns
true if the given pool was terminated successfully. |
void |
updateSettings(Settings settings) |
nodeName
public static final String THREADPOOL_GROUP
public ThreadPool(String name)
@Inject public ThreadPool(Settings settings, @Nullable NodeSettingsService nodeSettingsService)
public long estimatedTimeInMillis()
public org.apache.lucene.util.Counter estimatedTimeInMillisCounter()
public ThreadPoolInfo info()
public ThreadPool.Info info(String name)
public ThreadPoolStats stats()
public Executor generic()
public ScheduledExecutorService scheduler()
public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, TimeValue interval)
public ScheduledFuture<?> schedule(TimeValue delay, String name, Runnable command)
public void shutdown()
public void shutdownNow()
public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException
InterruptedException
public void updateSettings(Settings settings)
public static boolean terminate(ExecutorService service, long timeout, TimeUnit timeUnit)
true
if the given service was terminated successfully. If the termination timed out,
the service is null
this method will return false
.public static boolean terminate(ThreadPool pool, long timeout, TimeUnit timeUnit)
true
if the given pool was terminated successfully. If the termination timed out,
the service is null
this method will return false
.Copyright © 2009–2015. All rights reserved.