Package org.springframework.batch.repeat.support

Class ThrottleLimitResultQueue<T>

java.lang.Object

org.springframework.batch.repeat.support.ThrottleLimitResultQueue<T>

public class ThrottleLimitResultQueue<T>
extends Object

An implementation of the ResultQueue that throttles the number of expected results, limiting it to a maximum at any given time.

Author:

Dave Syer

Constructor Summary

Constructors

Constructor	Description
ThrottleLimitResultQueue(int throttleLimit)

Method Summary

Modifier and Type	Method	Description
void	expect()	Tell the queue to expect one more result.
boolean	isEmpty()
boolean	isExpecting()
void	put(T holder)
T	take()

Methods inherited from class java.lang.Object

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

Constructor Details

ThrottleLimitResultQueue

public ThrottleLimitResultQueue(int throttleLimit)

Parameters:

throttleLimit - the maximum number of results that can be expected at any given time.

Method Details

isEmpty

public boolean isEmpty()

isExpecting

public boolean isExpecting()

expect

public void expect()
            throws InterruptedException

Tell the queue to expect one more result. Blocks until a new result is available if already expecting too many (as determined by the throttle limit).

Throws:

InterruptedException

See Also:

• ResultQueue.expect()

put

public void put(T holder)
         throws IllegalArgumentException

Throws:

IllegalArgumentException

take

public T take()
       throws NoSuchElementException,
InterruptedException

Throws:

NoSuchElementException

InterruptedException