Comment gérer les exceptions des tâches ExecutorService à l'aide de Callable ?

Handling Exceptions from Java ExecutorService Tasks Using Callable

In an attempt to process exceptions from Java ExecutorService tasks, it's common to subclass ThreadPoolExecutor and override its afterExecute method. However, this approach may not always work as expected.

Instead of overriding afterExecute, consider utilizing Callable tasks. Callable.call() allows for throwing checked exceptions, which can be propagated back to the calling thread.

Here's an example using Callable:

Callable task = ...;
Future future = executor.submit(task);

// Perform other tasks while the Callable executes

try {
    future.get();
} catch (ExecutionException ex) {
    // Process the exception thrown by the Callable
    ex.getCause().printStackTrace();
}

When Callable.call() throws an exception, it is wrapped in an ExecutionException and rethrown by Future.get(). This provides a more robust exception handling mechanism compared to subclassing ThreadPoolExecutor.

Additionally, using Callable gives you the ability to re-submit the task if the exception is recoverable, providing greater flexibility in error handling.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!