Package org.infinispan.commons.util.concurrent

Class BlockingRejectedExecutionHandler

java.lang.Object

org.infinispan.commons.util.concurrent.BlockingRejectedExecutionHandler

All Implemented Interfaces:

RejectedExecutionHandler

public class BlockingRejectedExecutionHandler
extends Object
implements RejectedExecutionHandler

A handler for rejected tasks that runs the task if the current thread is a blocking thread otherwise it rejects the task.

Since:

10.1

Author:

wburns

Method Summary

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

Method Detail

getInstance

public static BlockingRejectedExecutionHandler getInstance()

rejectedExecution

public void rejectedExecution(Runnable r,
                              ThreadPoolExecutor executor)

rejectedExecution

public void rejectedExecution(Runnable r,
                              ExecutorService executor)