org.aredis.util.concurrent

Interface RejectedTaskHandler

public interface RejectedTaskHandler

Interface specifying the action to be taken when a task is rejected by a LimitingTaskExecutor.

Author:

Suresh

Method Summary

Methods

Modifier and Type	Method and Description
void	rejectedExecution(Runnable r, LimitingTaskExecutor executor) Method that may be invoked by a LimitingTaskExecutor when execute cannot accept a task.

Method Detail

rejectedExecution

void rejectedExecution(Runnable r,
                     LimitingTaskExecutor executor)

Method that may be invoked by a LimitingTaskExecutor when execute cannot accept a task. This may occur when the max allowed tasks have already been submitted to the underlying ExecutorService and no queue slots are available because its bounds would be exceeded, if the underlying ExecutorService has rejected this task and it cannot be queued because the queue is full or there are no active tasks running to process queued tasks after their completion, or upon shutdown of the Executor.

In the absence of other alternatives, the method may throw an unchecked RejectedExecutionException, which will be propagated to the caller of execute.

Parameters:

r - the runnable task requested to be executed

executor - the executor attempting to execute this task

Throws:

RejectedExecutionException - if there is no remedy