Futuresのバッチが完了するのを待っている間にタイムアウトしましたか？

Question

CallableをExecutorに提出して作成したFuturesのセットがあります。擬似コード：

すべての完了まで、すべての先物を最大でn秒待機させたいと思います。私はFuture#get(timeout)と呼ぶことができることを知っていますが、ループ内のすべての先物について順番に呼び出すと、タイムアウトが加算されます。擬似コード：

get結果が準備完了するまでブロックします。したがって、最初のタイムアウトがタイムアウトの直前に完了し、2番目のタイムアウトがタイムアウトの直前に完了すると、実行時間全体がtimeoutではなく、number of futures * timeoutになります。

したがって、私はFutureのリストとタイムアウトのリストを受け取り、すべてを並行して実行し、その後の結果のコレクションを返します。何か案は？

Answer 1

あなたはExecutorService.invokeAllを使用することができます。

は、いずれか早い方のすべての完全またはタイムアウトが満了したときに自分のステータスと結果を含むFutureのリストを、返す、与えられたタスクを実行します。 Future.isDone()は、返されるリストの各要素について真です。復帰時に、完了していないタスクは取り消されます。完了したタスクは、通常どおりまたは例外をスローすることによって終了する可能性があることに注意してください。この操作の進行中に指定されたコレクションが変更された場合、このメソッドの結果は未定義です。

---

あなたはすでにあなたが監視する必要があるとinvokeAllを使用することはできませんFuture秒を持っている場合は、単にタイムアウトを自分で測定することができます。擬似コード：

このようにして、あなたのタイムアウトに達するまで残された時間を各自に与えます。