org.mule.util.concurrent

Class WaitPolicy

java.lang.Object

org.mule.util.concurrent.WaitPolicy

All Implemented Interfaces:

edu.emory.mathcs.backport.java.util.concurrent.RejectedExecutionHandler

public class WaitPolicy
extends Object
implements edu.emory.mathcs.backport.java.util.concurrent.RejectedExecutionHandler

A handler for unexecutable tasks that waits until the task can be submitted for execution or times out. Generously snipped from the jsr166 repository at: .

Constructor Summary

Constructors

Constructor and Description
WaitPolicy() Constructs a WaitPolicy which waits (almost) forever.
WaitPolicy(long time, edu.emory.mathcs.backport.java.util.concurrent.TimeUnit timeUnit) Constructs a WaitPolicy with timeout.

Method Summary

Methods

Modifier and Type	Method and Description
void	rejectedExecution(Runnable r, edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor e)

Methods inherited from class java.lang.Object

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

Constructor Detail

WaitPolicy

public WaitPolicy()

Constructs a WaitPolicy which waits (almost) forever.

WaitPolicy

public WaitPolicy(long time,
          edu.emory.mathcs.backport.java.util.concurrent.TimeUnit timeUnit)

Constructs a WaitPolicy with timeout. A negative time value is interpreted as Long.MAX_VALUE.

Method Detail

rejectedExecution

public void rejectedExecution(Runnable r,
                     edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor e)

Specified by:

rejectedExecution in interface edu.emory.mathcs.backport.java.util.concurrent.RejectedExecutionHandler