如何處理Java ExecutorService任務中的異常？

Java ExecutorService 任務中的異常處理

當利用Java 的ThreadPoolExecutor 在執行緒池大小受限的情況下並發執行任務時，管理任務期間可能出現的潛在異常至關重要執行。但是，為此目的使用 afterExecute 方法可能無法如預期般運作。

問題：

在提供的範例中：

protected void afterExecute(Runnable r, Throwable t) {
    super.afterExecute(r, t);
    if(t != null) {
        System.out.println("Got an error: " + t);
    } else {
        System.out.println("Everything's fine--situation normal!");
    }
}

任務拋出例外時，不會呼叫 afterExecute 方法。相反，即使發生異常，輸出也會錯誤地指示「一切正常」。這是因為由於使用submit(Runnable r)而不是submit(Callable c)而不會引發例外狀況。

Callable vs. Runnable

有效處理任務異常，向ThreadPoolExecutor提交任務時建議使用Callable而不是Runnable。 Callable 的 call() 方法可以拋出已檢查的例外狀況，然後透過 Future.get() 傳回呼叫執行緒。

範例：

Callable<String> task = ...
Future<String> future = executor.submit(task);

// Do something else while task executes...

try {
    String result = future.get();
} catch (ExecutionException ex) {
    Throwable cause = ex.getCause();
    // Handle the exception as necessary
}

If Callable.call() 方法拋出異常，它將被包裝在ExecutionException 中並由Future.get() 拋出。這允許在調用線程中正確處理異常。

注意： 需要注意的是，此解決方案可能會在 Future.get() 呼叫期間阻塞呼叫執行緒。對於更高階的錯誤處理和復原場景，請考慮使用專門的錯誤處理框架或自訂實作。

以上是如何處理Java ExecutorService任務中的異常？的詳細內容。更多資訊請關注PHP中文網其他相關文章！