Executor 和 ExecutorService API 是管理和控制執(zhí)行緒執(zhí)行的重要工具。它們是 java.util.concurrent 套件的一部分。它們透過抽象線程創(chuàng)建、管理和同步的複雜性來簡化並發(fā)編程的過程。

Executors 是 java.util.concurrent 套件中的實用工具類，提供用於建立和管理不同類型的 ExecutorService 實例的工廠方法。它簡化了建立執(zhí)行緒池的過程，讓我們可以輕鬆地建立和管理不同配置的執(zhí)行器實例。

Executor API 它是從 Java 1.5 開始提供的介面。它提供了execute(Runnable command)方法。 這是基本接口，ExecutorService 擴展了該接口。給定的命令將在將來由新線程或線程池中的線程或同一線程執(zhí)行，並且不會返回 void。

ExecutorService API 它是從 Java 1.5 開始提供的介面。它提供了多種方法來控制並發(fā)程式設(shè)計中任務(wù)的執(zhí)行。它支援可運行和可調(diào)用任務(wù)。它傳回任務(wù)狀態(tài)的 Future。以下是最常用的方法。

• submit() 接受 Callable 或 Runnable 任務(wù)並傳回 Future 型態(tài)結(jié)果。

• invokeAny() 接受一組要執(zhí)行的任務(wù)，並傳回任何一個任務(wù)成功執(zhí)行的結(jié)果。

• invokeAll() 接受要執(zhí)行的任務(wù)集合，並以 Future 物件類型清單的形式傳回所有任務(wù)的結(jié)果。

• shutdown() 不會立即停止執(zhí)行器服務(wù)，但不接受新任務(wù)。一旦所有目前正在運行的任務(wù)完成，它就會關(guān)閉執(zhí)行器服務(wù)。

• shutdownNow() 會嘗試立即停止執(zhí)行器服務(wù)，但不保證所有正在執(zhí)行的任務(wù)會同時停止。

• awaitTermination(long timeout, TimeUnit unit) 阻塞/等待，直到所有任務(wù)完成或發(fā)生超時或當(dāng)前線程被中斷，以先發(fā)生者為準(zhǔn)。當(dāng)前線程將被阻塞。

ExecutorService 的類型

• FixThreadPool 它會建立具有指定執(zhí)行緒數(shù)的固定大小執(zhí)行緒池。提交的任務(wù)是並發(fā)執(zhí)行的。如果沒有任務(wù)，則執(zhí)行緒將處於空閒狀態(tài)，直到任務(wù)到達。如果線程繁忙，任務(wù)將被加入到佇列中。

ExecutorService fixedThreadPool = Executors.newScheduledThreadPool(5);
Future<String> submit = fixedThreadPool.submit(() -> {
    System.out.println("Task executed by " + Thread.currentThread().getName());
    return Thread.currentThread().getName();
});
fixedThreadPool.shutdown();

• CachedThreadPool 建立執(zhí)行緒池並根據(jù)工作負載自動調(diào)整池中所需的執(zhí)行緒數(shù)。如果執(zhí)行緒空閒超過60秒，就會被終止。這對於動態(tài)負載非常有效。由於線程將在空閒超時後被殺死，因此這裡可以更好地利用資源。

ExecutorService fixedThreadPool = Executors.newCachedThreadPool();
Future<String> submit = fixedThreadPool.submit(() -> {
    System.out.println("Task executed by " + Thread.currentThread().getName());
    return Thread.currentThread().getName();
});
fixedThreadPool.shutdown();

• SingleThreadExecutor 建立單線程，任務(wù)依序執(zhí)行。這裡沒有並行處理。

ExecutorService fixedThreadPool = Executors.newSingleThreadExecutor();
Future<String> submit = fixedThreadPool.submit(() -> {
    System.out.println("Task executed by " + Thread.currentThread().getName());
    return Thread.currentThread().getName();
});
fixedThreadPool.shutdown()

• ScheduledThreadPool/ScheduledExecutor 它會建立一個線程或 trhead 池，能夠定期運行任務(wù)或在一定延遲後運行。

ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor(); // Single-threaded scheduler
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(5); // Multi-threaded scheduler

scheduler.schedule(task, 10, TimeUnit.SECONDS); // Schedule task to run after 10 seconds.

scheduler.scheduleAtFixedRate(task, 5, 10, TimeUnit.SECONDS);
    //It schedules a task to run every 10 seconds with an initial delay of 5 seconds.
scheduler.scheduleWithFixedDelay(task, 5, 10, TimeUnit.SECONDS);
   //It schedules a task to run with a fixed delay of 10 seconds between the end of one execution and the start of the next, with an initial delay of 5 seconds.
scheduler.schedule(() -> scheduler.shutdown(), 20, TimeUnit.SECONDS);
   //It schedules a shutdown of the scheduler after 20 seconds to stop the example.

向 ExecutorService 提交任務(wù)
可以使用execute() 和submit() 方法將任務(wù)提交給ExecutorService。 execute()方法用於Runnable任務(wù)，而submit()可以處理Runnable和Callable任務(wù)。 ”

 executor.execute(new RunnableTask()); //fire-and-forgot
 executor.submit(new CallableTask()); //returns the status of task

關(guān)閉 ExecutorService
關(guān)閉 ExecutorService 以釋放資源非常重要。您可以使用 shutdown() 和 shutdownNow() 方法來執(zhí)行此操作。

executor.shutdown(); // Initiates an orderly shutdown"
executor.shutdownNow(); // Attempts to stop all actively executing tasks.
executor.awaitTermination(long timeout, TimeUnit unit); //blocks the thread until all tasks are completed or timeout occurs or current thread is interrupted, whichever happens first. Returns `true `is tasks completed, otherwise `false`.

建議的關(guān)閉方法

executor.shutdown();
try {
    // Wait for tasks to complete or timeout
    if (!executor.awaitTermination(120, TimeUnit.SECONDS)) {
        // If the timeout occurs, force shutdown
        executor.shutdownNow();      
    }
} catch (InterruptedException ex) {
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}

關(guān)於 Runnable

• Runnable 是一個接口，代表一個可以透過執(zhí)行緒運行的任務(wù)。
• 我們可以使用Threads或Executor服務(wù)來執(zhí)行Runnable任務(wù)。
• Runnable 有 run() 方法，且不傳回任何資料。
• 我們不能拋出已檢查的異常。

關(guān)於 Callable

• 1.5中引入
• 它有 call() 方法並傳回型別 V。
• 它包含 throws Exception 的意思，我們可以拋出檢查異常。

關(guān)於未來

• 它代表任何任務(wù)的未來結(jié)果。
• 請求處理完成後，結(jié)果最終會在Future中出現(xiàn)。
• boolean isDone() 傳回請求處理的狀態(tài)。如果完成則為 true，否則為 false。
• boolean cancel(boolean mayInterruptIfRunning) 取消提交的任務(wù)。如果我們將 mayInterruptIfRunning 傳遞為 false，那麼它不會取消已經(jīng)啟動的任務(wù)。
• boolean isCancelled() 傳回任務(wù)是否取消。
• V get() 傳回任務(wù)結(jié)果。如果任務(wù)未完成，則阻塞執(zhí)行緒。
• V get(long timeout, TimeUnit unit) 如有必要，最多等待給定時間以完成計算，然後檢索其結(jié)果。如果計算未完成，將在指定時間後拋出 TimeoutException。

快樂編碼和學(xué)習(xí)！ ！ ！

如有任何問題請留言。

以上是Java中Executor服務(wù)概述的詳細內(nèi)容。更多資訊請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！