Package 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, Artem Bilan

Constructor Summary

Constructors

Constructor	Description
CallerBlocksPolicy(long maxWait)	Construct instance based on the provided maximum wait time.

Method Summary

Modifier and Type	Method	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 Details

CallerBlocksPolicy

public CallerBlocksPolicy(long maxWait)

Construct instance based on the provided maximum wait time.

Parameters:

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

Method Details

rejectedExecution

public void rejectedExecution(Runnable r, ThreadPoolExecutor executor)

Specified by:

rejectedExecution in interface RejectedExecutionHandler