Module org.elasticsearch.server
Class EsRejectedExecutionHandler
java.lang.Object
org.elasticsearch.common.util.concurrent.EsRejectedExecutionHandler
- All Implemented Interfaces:
RejectedExecutionHandler
- Direct Known Subclasses:
EsAbortPolicy
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidprotected static EsRejectedExecutionExceptionnewRejectedException(Runnable r, ThreadPoolExecutor executor, boolean isExecutorShutdown) voidregisterCounter(MeterRegistry meterRegistry, String metric_name, String threadpool_name) longrejected()The number of rejected executions.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface java.util.concurrent.RejectedExecutionHandler
rejectedExecution
-
Constructor Details
-
EsRejectedExecutionHandler
public EsRejectedExecutionHandler()
-
-
Method Details
-
rejected
public long rejected()The number of rejected executions. -
incrementRejections
protected void incrementRejections() -
registerCounter
public void registerCounter(MeterRegistry meterRegistry, String metric_name, String threadpool_name) -
newRejectedException
protected static EsRejectedExecutionException newRejectedException(Runnable r, ThreadPoolExecutor executor, boolean isExecutorShutdown)
-