ExecutorService如何處理異常和錯誤

在使用ExecutorService時，處理異常和錯誤是非常重要的。以下是一些處理異常和錯誤的方法：

1. 使用try-catch語句：在執行任務時，可以使用try-catch語句捕獲異常。這樣，當任務發生異常時，可以在catch塊中處理異常。

ExecutorService executorService = Executors.newFixedThreadPool(5);

Runnable task = () -> {
    try {
        // 你的任務代碼
    } catch (Exception e) {
        // 處理異常
        e.printStackTrace();
    }
};

executorService.submit(task);

2. 使用Future.get()方法：當你使用submit()方法提交一個任務時，它會返回一個Future對象。你可以調用Future.get()方法來獲取任務的執行結果。如果任務發生異常，get()方法會拋出一個ExecutionException，你可以捕獲這個異常并處理它。

ExecutorService executorService = Executors.newFixedThreadPool(5);

Future<?> future = executorService.submit(() -> {
    // 你的任務代碼
});

try {
    future.get();
} catch (InterruptedException e) {
    // 處理中斷異常
    e.printStackTrace();
} catch (ExecutionException e) {
    // 處理任務執行異常
    e.getCause().printStackTrace();
}

3. 使用Thread.UncaughtExceptionHandler：你可以為線程池中的每個線程設置一個UncaughtExceptionHandler，當線程發生未捕獲的異常時，這個處理器會被調用。這樣，你可以在處理器中處理異常。

ExecutorService executorService = Executors.newFixedThreadPool(5);

ThreadFactory threadFactory = runnable -> {
    Thread thread = new Thread(runnable);
    thread.setUncaughtExceptionHandler((t, e) -> {
        // 處理未捕獲的異常
        e.printStackTrace();
    });
    return thread;
};

executorService = Executors.newFixedThreadPool(5, threadFactory);

executorService.submit(() -> {
    // 你的任務代碼
});

4. 自定義ThreadPoolExecutor：你可以繼承ThreadPoolExecutor類，并重寫afterExecute()方法。當任務執行完成后，無論是否發生異常，都會調用這個方法。你可以在這個方法中處理異常。

public class CustomThreadPoolExecutor extends ThreadPoolExecutor {

    public CustomThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
    }

    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        if (t == null && r instanceof java.util.concurrent.Future<?>) {
            try {
                java.util.concurrent.Future<?> future = (java.util.concurrent.Future<?>) r;
                if (future.isDone()) {
                    future.get();
                }
            } catch (CancellationException ce) {
                t = ce;
            } catch (ExecutionException ee) {
                t = ee.getCause();
            } catch (InterruptedException ie) {
                Thread.currentThread().interrupt(); // ignore/reset
            }
        }
        if (t != null) {
            // 處理異常
            t.printStackTrace();
        }
    }
}

// 使用自定義的線程池執行任務
ExecutorService executorService = new CustomThreadPoolExecutor(5, 10, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<>());

executorService.submit(() -> {
    // 你的任務代碼
});

總之，處理ExecutorService中的異常和錯誤需要根據你的需求選擇合適的方法。在實際應用中，你可以結合使用這些方法來確保任務執行過程中的異常得到妥善處理。