ExecutorCompletionService クラス

定義

[Android.Runtime.Register("java/util/concurrent/ExecutorCompletionService", DoNotGenerateAcw=true)]
[Java.Interop.JavaTypeParameters(new System.String[] { "V" })]
public class ExecutorCompletionService : Java.Lang.Object, IDisposable, Java.Interop.IJavaPeerable, Java.Util.Concurrent.ICompletionService

[<Android.Runtime.Register("java/util/concurrent/ExecutorCompletionService", DoNotGenerateAcw=true)>]
[<Java.Interop.JavaTypeParameters(new System.String[] { "V" })>]
type ExecutorCompletionService = class
    inherit Object
    interface ICompletionService
    interface IJavaObject
    interface IDisposable
    interface IJavaPeerable

継承

Object

Object

ExecutorCompletionService

属性

RegisterAttribute JavaTypeParametersAttribute

実装

IJavaObject IJavaPeerable ICompletionService IDisposable

注釈

指定されたタスクを実行するために使用する Executor ACompletionService。 このクラスは、送信されたタスクが完了すると、次を使用して takeアクセス可能なキューに配置されるように配置します。 このクラスは、タスクのグループを処理する際の一時的な使用に適した軽量です。

<b>使用例</b>

ある特定の問題に対して一連のソルバーがあり、それぞれが何らかの型 Resultの値を返し、それらを同時に実行して、null 以外の値を返すそれぞれの結果を処理 use(Result r)したいとします。 これは次のように記述できます。

{@code
            void solve(Executor e,
                       Collection<Callable<Result>> solvers)
                throws InterruptedException, ExecutionException {
              CompletionService<Result> cs
                  = new ExecutorCompletionService<>(e);
              solvers.forEach(cs::submit);
              for (int i = solvers.size(); i > 0; i--) {
                Result r = cs.take().get();
                if (r != null)
                  use(r);
              }
            }}

代わりに、一連のタスクの最初の null 以外の結果を使用し、例外が発生した場合は無視し、最初のタスクの準備ができたら他のすべてのタスクを取り消したいとします。

{@code
            void solve(Executor e,
                       Collection<Callable<Result>> solvers)
                throws InterruptedException {
              CompletionService<Result> cs
                  = new ExecutorCompletionService<>(e);
              int n = solvers.size();
              List<Future<Result>> futures = new ArrayList<>(n);
              Result result = null;
              try {
                solvers.forEach(solver -> futures.add(cs.submit(solver)));
                for (int i = n; i > 0; i--) {
                  try {
                    Result r = cs.take().get();
                    if (r != null) {
                      result = r;
                      break;
                    }
                  } catch (ExecutionException ignore) {}
                }
              } finally {
                futures.forEach(future -> future.cancel(true));
              }

              if (result != null)
                use(result);
            }}

1\.5 で追加されました。

の Java ドキュメントjava.util.concurrent.ExecutorCompletionService

このページの一部は、Android オープンソース プロジェクトによって作成および共有され、クリエイティブ コモンズ 2.5 属性ライセンスに記載されている条件に従って使用される作業に基づく変更です。

コンストラクター

プロパティ

メソッド

明示的なインターフェイスの実装

拡張メソッド

適用対象