IExecutorService インターフェイス

定義

[Android.Runtime.Register("java/util/concurrent/ExecutorService", "", "Java.Util.Concurrent.IExecutorServiceInvoker")]
public interface IExecutorService : IDisposable, Java.Interop.IJavaPeerable, Java.Util.Concurrent.IExecutor

[<Android.Runtime.Register("java/util/concurrent/ExecutorService", "", "Java.Util.Concurrent.IExecutorServiceInvoker")>]
type IExecutorService = interface
    interface IExecutor
    interface IJavaObject
    interface IDisposable
    interface IJavaPeerable

派生

Java.Util.Concurrent.AbstractExecutorService

Java.Util.Concurrent.IScheduledExecutorService

Java.Util.Concurrent.ScheduledThreadPoolExecutor

属性

RegisterAttribute

実装

IJavaObject IJavaPeerable IExecutor IDisposable

注釈

終了を管理するメソッドと、1 つ以上の非同期タスクの進行状況を追跡するためのExecutorを生成できるメソッドを提供するFuture。

ExecutorServiceをシャットダウンすると、新しいタスクが拒否されます。 ExecutorServiceをシャットダウンするには、2 つの異なる方法が用意されています。 #shutdown メソッドを使用すると、以前に送信されたタスクを終了する前に実行できます。一方、#shutdownNow メソッドは待機中のタスクを開始できず、現在実行中のタスクを停止しようとします。 終了すると、Executor にはアクティブに実行されているタスクがなく、実行を待機しているタスクも、新しいタスクも送信できません。 リソースの再利用を許可するには、未使用の ExecutorService をシャットダウンする必要があります。

メソッド submitは、実行の取り消しや完了の待機に使用できるFutureを作成して返すことによって、基本メソッドExecutor#execute(Runnable)を拡張します。 メソッド invokeAny および invokeAll 、最も一般的に役立つ一括実行形式を実行し、タスクのコレクションを実行した後、少なくとも 1 つ以上の完了を待機します。 (クラス ExecutorCompletionService を使用して、これらのメソッドのカスタマイズされたバリアントを記述できます)。

Executors クラスは、このパッケージで提供される Executor サービスのファクトリ メソッドを提供します。

<h2>使用例</h2>

スレッド プール サービス内のスレッドが要求を受信するネットワーク サービスのスケッチを次に示します。 構成済みの Executors#newFixedThreadPool ファクトリ メソッドを使用します。

{@code
            class NetworkService implements Runnable {
              private final ServerSocket serverSocket;
              private final ExecutorService pool;

              public NetworkService(int port, int poolSize)
                  throws IOException {
                serverSocket = new ServerSocket(port);
                pool = Executors.newFixedThreadPool(poolSize);
              }

              public void run() { // run the service
                try {
                  for (;;) {
                    pool.execute(new Handler(serverSocket.accept()));
                  }
                } catch (IOException ex) {
                  pool.shutdown();
                }
              }
            }

            class Handler implements Runnable {
              private final Socket socket;
              Handler(Socket socket) { this.socket = socket; }
              public void run() {
                // read and service request on socket
              }
            }}

次のように、 ExecutorService を確立して閉じる (シャットダウン、終了するまでブロックする) こともできます。別の Executors ファクトリメソッドを使用して示します。

{@code
            try (ExecutorService e =  Executors.newWorkStealingPool()) {
              // submit or execute many tasks with e ...
            }}

さらにカスタマイズも可能です。 たとえば、次のメソッドは、2 つのフェーズで ExecutorService をシャットダウンします。まず、 shutdown を呼び出して受信タスクを拒否し、必要に応じて shutdownNowを呼び出して、残りのタスクを取り消します。

{@code
            void shutdownAndAwaitTermination(ExecutorService pool) {
              pool.shutdown(); // Disable new tasks from being submitted
              try {
                // Wait a while for existing tasks to terminate
                if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
                  pool.shutdownNow(); // Cancel currently executing tasks
                  // Wait a while for tasks to respond to being cancelled
                  if (!pool.awaitTermination(60, TimeUnit.SECONDS))
                      System.err.println("Pool did not terminate");
                }
              } catch (InterruptedException ex) {
                // (Re-)Cancel if current thread also interrupted
                pool.shutdownNow();
                // Preserve interrupt status
                Thread.currentThread().interrupt();
              }
            }}

メモリ整合性の影響: RunnableまたはCallable タスクを ExecutorService<i>happen-before</i>に送信する前のスレッド内のアクション。そのタスクによって実行されたアクションは、結果がFuture.get()を介して取得される前に発生します。

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

Javaドキュメント。

このページの一部は、Androidオープンソースプロジェクトによって作成および共有された作業に基づく変更でありCreative Commons 2.5属性ライセンスに記載されている条件に従って使用されます。