如何表示Java未来结果的失败

Question

AFAIK将Callable/Runnable提交到ExecutorService是我想并行执行资源密集型代码的方法。因此，我的方法结构：

public class ServiceClass {
    protected final ExecutorService executorService = Executors.newCachedThreadPool();

    public Future<Result> getResult(Object params) {
        if (params == null) {
            return null; // In situations like this the method should fail
        }
        // Do other fast pre-processing stuff
        return executorService.submit(new CallProcessResult(params));
    }

    private class CallProcessResult implements Callable<Result> {
        private Object params;
        public CallProcessResult(Object params) {
            this.params = params;
        }
        @Override
        public Result call() throws Exception {
            // Compute result for given params
            // Failure may happen here too!
            return result;
        }
    }
}
public class Result {
    ...
}

我在上面的代码中标记了两个可能发生故障的点。对于这两种情况，可用于错误处理的选项非常不同。

在提交任务之前，可能会出现一些问题，例如参数无效，一些可能失败的快速预处理代码。

我在这里看到了几种表示失败的方式:

1. 如果提供给getResult的无效params立即返回null。在这种情况下，我必须检查getResult每次调用时是否返回null。
2. 抛出检查过的异常而不是上面的。
3. 实例化一个<代码>未来

在任务执行期间，我可能会遇到严重错误，如内存不足、文件损坏、文件不可用等。

1. 我认为在我的情况下更好的选择是返回null，因为任务的结果是一个对象。
2. 此外，我可以抛出检查过的异常并在ThreadPoolExecutor.afterExecute中处理它们（如NiranjanBhat所建议的）。请参阅处理来自JavaExecutorService任务的异常

哪种做法更好（在两种情况下）？

也许有一种不同的方法或者一种我应该使用的设计模式？

Answer 1

您可以使用 afterExecute 方法。这是在 ThreadPoolExecutor 中定义的，您需要覆盖它。
此方法在每个任务的执行完成后调用。您将在此回调方法中获取任务实例。您可以在任务中的某个变量中记录错误，并在此方法中访问它。

Answer 2

我建议，对于任务处理过程中的失败，您只需抛出一个适当的异常。不要在executor中为此添加任何特殊处理。将会发生的是，它将被捕获，并存储在< code >未来中。当调用< code>Future的< code>get方法时，它将引发< code>ExecutionException，然后< code>get的调用方可以对其进行解包和处理。这基本上就是普通异常处理被转换成< code >可调用/未来范例的方式。这看起来像这样:

    Future<Result> futureResult = serviceClass.getResult("foo");

    try {
        Result result = futureResult.get();
        // do something with result
    }
    catch (ExecutionException ee) {
        Throwable e = ee.getCause();
        // do something with e
    }

假设< code>get的调用方必须处理< code > execution exception s，那么您可以利用这一点来处理提交期间的失败。为此，您可以构造一个类似于Apache Commons的< code>constantFuture的< code>Future，但是它抛出一个给定的异常，而不是返回一个给定值。我不认为JDK有这样的东西，但是写起来很简单(虽然很乏味):

public class FailedFuture<T> implements Future<T> {
    private final Throwable exception;

    public FailedFuture(Throwable exception) {
        this.exception = exception;
    }

    @Override
    public T get() throws ExecutionException {
        throw new ExecutionException(exception);
    }

    @Override
    public T get(long timeout, TimeUnit unit) throws ExecutionException {
        return get();
    }

    @Override public boolean cancel(boolean mayInterruptIfRunning) { return false; }
    @Override public boolean isCancelled() { return false; }
    @Override public boolean isDone() { return true; }
}

这有点危险-您在同步调用方法期间出现故障，并使其看起来像在异步调用方法期间发生故障。您正在将处理错误的负担从实际导致错误的代码转移到稍后运行的代码。不过，这确实意味着您可以将所有故障处理代码放在一个地方；这可能是一个足够的优势，让这一切变得值得。