Package org.springframework.batch.repeat.support

Class ResultHolderResultQueue

java.lang.Object
org.springframework.batch.repeat.support.ResultHolderResultQueue
@Deprecated(since="5.0", forRemoval=true) public class ResultHolderResultQueue 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
    ResultHolderResultQueue(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(org.springframework.batch.repeat.support.ResultHolder holder)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    org.springframework.batch.repeat.support.ResultHolder
    take()
    Deprecated, for removal: This API element is subject to removal in a future version.
    Get the next result as soon as it becomes available.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ResultHolderResultQueue

      public ResultHolderResultQueue(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(org.springframework.batch.repeat.support.ResultHolder holder) throws IllegalArgumentException
      Deprecated, for removal: This API element is subject to removal in a future version.
      Throws:
      IllegalArgumentException

    • take

      public org.springframework.batch.repeat.support.ResultHolder take() throws NoSuchElementException, InterruptedException
      Deprecated, for removal: This API element is subject to removal in a future version.
      Get the next result as soon as it becomes available.

      Release result immediately if:
      • There is a result that is continuable.
      Otherwise block if either:
      • There is no result (as per contract of ResultQueue).
      • The number of results is less than the number expected.
      Error if either:
      • Not expecting.
      • Interrupted.
      Throws:
      NoSuchElementException
      InterruptedException
      See Also:
      • ResultQueue.take()