gobblin.util.executors

Class ForceQueuePolicy

java.lang.Object

gobblin.util.executors.ForceQueuePolicy

All Implemented Interfaces:

RejectedExecutionHandler

public class ForceQueuePolicy
extends Object
implements RejectedExecutionHandler

RejectedExecutionHandler that just re-attempts to put into the queue.

Constructor Summary

Constructors

Constructor and Description
ForceQueuePolicy()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ForceQueuePolicy

public ForceQueuePolicy()

Method Detail

rejectedExecution

public void rejectedExecution(Runnable r,
                              ThreadPoolExecutor executor)

Specified by:

rejectedExecution in interface RejectedExecutionHandler