コンストラクターの詳細

• ThrottleLimitResultQueue

  public ThrottleLimitResultQueue(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(T holder)
           throws java.lang.IllegalArgumentException

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

  パラメーター:

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

  例外:

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

• take

  public T take()
         throws java.util.NoSuchElementException,
                java.lang.InterruptedException

  次に利用可能な結果を取得します。まだ利用可能な結果がない場合はブロックします。

  戻り値:

  以前に寄託された結果

  例外:

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

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