Package org.elasticsearch.common.util.concurrent

Class EsAbortPolicy

java.lang.Object
org.elasticsearch.common.util.concurrent.EsAbortPolicy
All Implemented Interfaces:
java.util.concurrent.RejectedExecutionHandler, XRejectedExecutionHandler
public class EsAbortPolicy
extends java.lang.Object
implements XRejectedExecutionHandler

  • Constructor Summary

    Constructors
    Constructor Description
    EsAbortPolicy()  

  • Method Summary

    Modifier and Type Method Description
    long rejected()
    The number of rejected executions.
    void rejectedExecution​(java.lang.Runnable r, java.util.concurrent.ThreadPoolExecutor executor)  

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • EsAbortPolicy

      public EsAbortPolicy()

  • Method Details

    • rejectedExecution

      public void rejectedExecution​(java.lang.Runnable r, java.util.concurrent.ThreadPoolExecutor executor)
      Specified by:
      rejectedExecution in interface java.util.concurrent.RejectedExecutionHandler

    • rejected

      public long rejected()
      Description copied from interface: XRejectedExecutionHandler
      The number of rejected executions.
      Specified by:
      rejected in interface XRejectedExecutionHandler