コンストラクターの詳細

• ResultHolderResultQueue

  public ResultHolderResultQueue(int throttleLimit)

  パラメーター:

  throttleLimit - 任意の時点で予想できる結果の最大数。

メソッドの詳細

• isEmpty

  public boolean isEmpty()

  ブロックして待機する必要なしに、take() から利用可能な結果があることを確認するためにマネージャースレッドによって使用されます。

  戻り値:

  利用可能な結果がない場合は true

• isExpecting

  public boolean isExpecting()

  結果が予想されるかどうかを確認します。通常、終了時にキューを排出するためにマネージャースレッドによって使用されます。

  戻り値:

  より多くの結果が予想されるが、おそらくまだ利用できない場合は true。

• expect

  public void expect()
              throws java.lang.InterruptedException

  キューにもう 1 つの結果を期待するように伝えます。（スロットル制限によって決定されるように）予想される数が多すぎる場合、新しい結果が利用可能になるまでブロックします。

  例外:

  java.lang.InterruptedException - 呼び出しがブロックされ、その後中断された場合。

  関連事項:

  ResultQueue.expect()

• put

  public void put(org.springframework.batch.repeat.support.ResultHolder holder)
           throws java.lang.IllegalArgumentException

  結果を期待すると、クライアントはこのメソッドを呼び出して期待に応えます。manager-worker パターンでは、ワーカーはこのメソッドを呼び出して、完了したタスクの結果を収集のためにキューに入れます。

  パラメーター:

  holder - 後で収集するための結果。

  例外:

  java.lang.IllegalArgumentException - キューが新しい結果を期待していない場合

• take

  public org.springframework.batch.repeat.support.ResultHolder take()
                                                             throws java.util.NoSuchElementException,
                                                                    java.lang.InterruptedException

  利用可能になり次第、次の結果を取得します。
  
  次の場合は、結果をすぐにリリースします。

  • 継続可能な結果があります。

  それ以外の場合は、次のいずれかの場合にブロックします。

  • 結果はありません（ResultQueue の契約による）。
  • 結果の数が予想数より少なくなっています。

  次のいずれかの場合のエラー:

  • 期待していません。
  • 中断されました。

  戻り値:

  以前に寄託された結果

  例外:

  java.util.NoSuchElementException - 期待される結果がない場合

  java.lang.InterruptedException - 待機中に操作が中断された場合

  関連事項:

  ResultQueue.take()