org.springframework.integration.util

Class CallerBlocksPolicy

java.lang.Object

org.springframework.integration.util.CallerBlocksPolicy

All Implemented Interfaces:

RejectedExecutionHandler

public class CallerBlocksPolicy
extends Object
implements RejectedExecutionHandler

A RejectedExecutionHandler that blocks the caller until the executor has room in its queue, or a timeout occurs (in which case a RejectedExecutionException is thrown.

Since:

3.0.3

Author:

Gary Russell

Constructor Summary

Constructors

Constructor and Description
CallerBlocksPolicy(long maxWait)

Method Summary

Methods

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

CallerBlocksPolicy

public CallerBlocksPolicy(long maxWait)

Parameters:

maxWait - The maximum time to wait for a queue slot to be available, in milliseconds.

Method Detail

rejectedExecution

public void rejectedExecution(Runnable r,
                     ThreadPoolExecutor executor)

Specified by:

rejectedExecution in interface RejectedExecutionHandler