Package org.infinispan.commons.util.concurrent

Class NonBlockingRejectedExecutionHandler

  • All Implemented Interfaces:
    java.util.concurrent.RejectedExecutionHandler
    public class NonBlockingRejectedExecutionHandler
extends java.lang.Object
implements java.util.concurrent.RejectedExecutionHandler
    A handler for rejected tasks that runs the task if the current thread is a non blocking thread otherwise it blocks until the task can be added to the underlying queue
    Since:
    10.1
    Author:
    wburns

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static java.util.concurrent.RejectedExecutionHandler getInstance()  
      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

    • Method Detail

      • getInstance

        public static java.util.concurrent.RejectedExecutionHandler getInstance()

      • rejectedExecution

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