ExecutorsService.submit詳解

一、submit方法的概述

submit是ExecutorService介面提供的一個提交任務的方法，用於提交一個Runnable或Callable任務到線程池中執行。該方法會返回一個Future對象，Future對象可以用來獲取任務執行結果或取消任務執行。

二、submit方法的重載

submit方法提供了多個重載，用於支持不同類型的任務。下面是submit方法重載的幾種形式：

// 提交一個Runnable任務，並返回一個Future對象
Future submit(Runnable task);

// 提交一個Callable任務，並返回一個Future對象
 Future submit(Callable task);

// 提交一個Runnable任務和一個結果result，返回一個Future對象
 Future submit(Runnable task, T result);

三、submit方法的執行過程

當我們提交一個任務後，submit方法首先會檢查線程池是否有空閑線程可用來執行該任務。如果有，submit方法會把任務直接提交給一個空閑線程執行，並返回一個表示該任務執行狀態的Future對象；如果沒有，submit方法會把該任務添加到線程池的等待隊列中等待執行，並返回一個表示該任務排隊狀態的Future對象。當線程池的某個線程空閑時，會從等待隊列中取出頭部的任務並交給該線程執行。

四、submit方法與execute方法的區別

ExecutorService提供了兩個提交任務的方法：submit和execute。兩者最大的區別在於submit方法可以返回一個表示任務執行結果的Future對象，而execute方法不返回任何結果。

// 提交一個Runnable任務，execute方法不返回結果
void execute(Runnable command);

由於submit方法可以返回執行結果，因此它的使用範圍更廣，而execute方法主要用於提交不需要返回結果的任務。

五、submit方法的異常處理

當我們提交一個Callable任務時，任務可能會拋出異常。如果我們沒有對異常進行捕獲處理，那麼任務所在的線程將會退出，從而導致該線程無法執行其他任務。為了避免這種情況的發生，我們可以通過捕獲Future.get方法拋出的ExecutionException異常來獲取任務執行過程中拋出的異常，並進行處理。

// 提交Callable任務，並進行異常處理
Future future = executorService.submit(new Callable() {
    @Override
    public String call() throws Exception {
        // 拋出異常
        throw new RuntimeException("Callable拋出異常");
    }
});

try {
    // 獲取任務執行結果
    String result = future.get();
} catch (InterruptedException e) {
    e.printStackTrace();
} catch (ExecutionException e) {
    Throwable cause = e.getCause();
    if (cause instanceof RuntimeException) {
        System.out.println("Catch RuntimeException: " + cause.getMessage());
    }
}

六、submit方法的使用示例

下面是一個使用submit方法的示例，該示例提交了10個任務到線程池中執行，並對任務執行過程中的異常進行了捕獲處理。

public class SubmitExample {
    public static void main(String[] args) {
        // 創建一個線程池
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        // 提交10個任務到線程池中執行
        List<Future> futures = new ArrayList();
        for (int i = 1; i <= 10; i++) {
            final int taskId = i;
            Future future = executorService.submit(new Callable() {
                @Override
                public String call() throws Exception {
                    // 拋出異常
                    if (taskId == 5) {
                        throw new RuntimeException("Callable任務拋出異常");
                    }
                    return "Task " + taskId + " executed.";
                }
            });
            futures.add(future);
        }

        // 獲取任務執行結果並輸出
        for (Future future : futures) {
            try {
                String result = future.get();
                System.out.println(result);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                Throwable cause = e.getCause();
                if (cause instanceof RuntimeException) {
                    System.out.println("Catch RuntimeException: " + cause.getMessage());
                }
            }
        }

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