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

備註

A Executor 提供管理終止的方法，以及能產生 Future 追蹤一個或多個非同步任務進度的方法。

ExecutorService An 可能會被關閉，這會導致它拒絕新的任務。 有兩種不同的方法用於關閉 ExecutorService。 此 #shutdown 方法允許先前提交的任務在終止前執行，同時 #shutdownNow 防止等待任務開始並嘗試停止目前執行中的任務。 終止時，執行者沒有正在執行的任務、等待執行的任務，且無法提交新的任務。 未使用的 ExecutorService 設備應該關閉，以便回收其資源。

方法submit透過建立並回傳Future一個可以用來取消執行和/或等待完成的基礎方法來擴展基礎方法Executor#execute(Runnable)。 方法 invokeAny 和 invokeAll 執行最常用的批量執行形式，執行一組任務，然後等待至少一個或全部完成。 （類別 ExecutorCompletionService 可用來撰寫這些方法的客製化變體。）

該 Executors 類別提供本套件中執行器服務的工廠方法。

<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 ...
            }}

此外，還能進行進一步的客製化。 例如，以下方法分兩階段關閉 ， 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();
              }
            }}

記憶體一致性效應：在將 or Callable 任務提交Runnable給<ExecutorService i<>> 之前，執行緒中的動作發生於該任務所採取的任何行動，而這些動作又在結果被檢索之前Future.get()發生。

已在1.5中新增。

Java 文件 java.util.concurrent.ExecutorService。

此頁面的部分是根據 Android 開放原始碼專案所建立和共用的工作進行修改，並根據 Creative Commons 2.5 屬性授權中所述的詞彙使用。