Package org.infinispan.commons.util.concurrent

Class NonBlockingRejectedExecutionHandler

java.lang.Object

org.infinispan.commons.util.concurrent.NonBlockingRejectedExecutionHandler

All Implemented Interfaces:

RejectedExecutionHandler

public class NonBlockingRejectedExecutionHandler
extends Object
implements 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

Modifier and Type	Method	Description
static RejectedExecutionHandler	getInstance()
void	rejectedExecution(Runnable r, ThreadPoolExecutor executor)

Methods inherited from class java.lang.Object

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

Method Details

getInstance

public static RejectedExecutionHandler getInstance()

rejectedExecution

public void rejectedExecution(Runnable r,
 ThreadPoolExecutor executor)

Specified by:

rejectedExecution in interface RejectedExecutionHandler