Package org.elasticsearch.common.util.concurrent

Class EsRejectedExecutionHandler

java.lang.Object

org.elasticsearch.common.util.concurrent.EsRejectedExecutionHandler

All Implemented Interfaces:

RejectedExecutionHandler

Direct Known Subclasses:

EsAbortPolicy

public abstract class EsRejectedExecutionHandler
extends Object
implements RejectedExecutionHandler

Constructor Summary

Constructors

Constructor	Description
EsRejectedExecutionHandler()

Method Summary

Modifier and Type	Method	Description
protected void	incrementRejections()
protected final EsRejectedExecutionException	newRejectedException(Runnable r, ThreadPoolExecutor executor, boolean isExecutorShutdown)
long	rejected()	The number of rejected executions.

Methods inherited from class java.lang.Object

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

Methods 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()

newRejectedException

protected final EsRejectedExecutionException newRejectedException(Runnable r,
 ThreadPoolExecutor executor,
 boolean isExecutorShutdown)