org.aredis.util.concurrent

Class LimitingTaskExecutor.TaskWrapper

java.lang.Object

org.aredis.util.concurrent.LimitingTaskExecutor.TaskWrapper

All Implemented Interfaces:

Runnable

Enclosing class:

LimitingTaskExecutor

public class LimitingTaskExecutor.TaskWrapper
extends Object
implements Runnable

TaskWrapper responsible for running the tasks which is submitted to the underlying ExecutorService. This class is declared as public so that the rejectExecution method can be called by the underlying executorService when rejecting an instance of TaskWrapper to indicate rejection of the task.

Author:

Suresh

Method Summary

Methods

Modifier and Type	Method and Description
void	rejectExecution() Marks the submitted task as rejected so that the LimitingTask executor can take an appropriate action to queue the task or reject it if the queue is full.
void	run()

Methods inherited from class java.lang.Object

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

Method Detail

rejectExecution

public void rejectExecution()

Marks the submitted task as rejected so that the LimitingTask executor can take an appropriate action to queue the task or reject it if the queue is full.

run

public void run()

Specified by:

run in interface Runnable