Package org.springframework.batch.repeat.support

Class ThrottleLimitResultQueue<T>

java.lang.Object
org.springframework.batch.repeat.support.ThrottleLimitResultQueue<T>
@Deprecated(since="5.0", forRemoval=true) public class ThrottleLimitResultQueue<T> extends Object
Deprecated, for removal: This API element is subject to removal in a future version.
since 5.0 with no replacement. Scheduled for removal in 6.0.
An implementation of the ResultQueue that throttles the number of expected results, limiting it to a maximum at any given time.
Author:
Dave Syer, Mahmoud Ben Hassine

  • Constructor Summary

    Constructors
    Constructor
    Description
    ThrottleLimitResultQueue(int throttleLimit)
    Deprecated, for removal: This API element is subject to removal in a future version.
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    expect()
    Deprecated, for removal: This API element is subject to removal in a future version.
    Tell the queue to expect one more result.
    boolean
    isEmpty()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    boolean
    isExpecting()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    put(T holder)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    T
    take()
    Deprecated, for removal: This API element is subject to removal in a future version.
     

    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)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Parameters:
      throttleLimit - the maximum number of results that can be expected at any given time.

  • Method Details

    • isEmpty

      public boolean isEmpty()
      Deprecated, for removal: This API element is subject to removal in a future version.

    • isExpecting

      public boolean isExpecting()
      Deprecated, for removal: This API element is subject to removal in a future version.

    • expect

      public void expect() throws InterruptedException
      Deprecated, for removal: This API element is subject to removal in a future version.
      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
      Deprecated, for removal: This API element is subject to removal in a future version.
      Throws:
      IllegalArgumentException

    • take

      public T take() throws NoSuchElementException, InterruptedException
      Deprecated, for removal: This API element is subject to removal in a future version.
      Throws:
      NoSuchElementException
      InterruptedException