如何使用Java ExecutorService管理線程

在Java中，ExecutorService是一個接口，它提供了一種將任務提交給執行的機制，同時提供了對執行過程的控制。以下是使用ExecutorService管理線程的一些基本步驟：

1. 創建一個ExecutorService實例：

   • 使用Executors類的靜態工廠方法來創建不同類型的ExecutorService。例如，Executors.newFixedThreadPool(int nThreads)會創建一個固定大小的線程池。

2. 提交任務：

   • 使用execute(Runnable command)方法提交一個實現了Runnable接口的任務。
   • 使用submit(Callable<T> task)方法提交一個實現了Callable接口的任務，該方法返回一個Future<T>對象，可以用來獲取任務的執行結果。

3. 控制任務的執行：

   • 可以使用shutdown()方法來關閉ExecutorService，它會等待已經提交的任務完成后再關閉。
   • 如果需要立即關閉并且不關心未完成的任務，可以使用shutdownNow()方法。

4. 處理任務結果：

   • 如果使用了submit()方法提交任務，可以通過返回的Future對象來檢查任務是否完成，并獲取其結果或取消任務。

5. 監控線程池的狀態：

   • ExecutorService提供了一些方法來獲取線程池的狀態，如getActiveCount()、getCompletedTaskCount()、getTaskCount()等。

下面是一個簡單的示例，展示了如何使用ExecutorService來管理線程：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class ExecutorServiceExample {
    public static void main(String[] args) {
        // 創建一個固定大小的線程池
        ExecutorService executor = Executors.newFixedThreadPool(2);

        // 提交一個Runnable任務
        executor.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println("Task 1 is running on thread " + Thread.currentThread().getName());
            }
        });

        // 提交一個Callable任務
        Future<String> future = executor.submit(new Callable<String>() {
            @Override
            public String call() throws Exception {
                Thread.sleep(1000);
                return "Task 2 completed";
            }
        });

        // 獲取Callable任務的結果
        try {
            String result = future.get();
            System.out.println(result);
        } catch (Exception e) {
            e.printStackTrace();
        }

        // 關閉線程池
        executor.shutdown();
    }
}

在這個例子中，我們創建了一個固定大小為2的線程池，提交了兩個任務（一個Runnable和一個Callable），然后關閉了線程池。Callable任務的結果被獲取并打印出來。

請注意，當使用ExecutorService時，應該小心處理異常，并確保在不再需要線程池時適當地關閉它，以避免資源泄露。