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)

Method Detail

getInstance

public static RejectedExecutionHandler getInstance()

rejectedExecution

public void rejectedExecution(Runnable r,
                              ThreadPoolExecutor executor)