Java 8：Lambda-Streams，按异常方法过滤

小编典典

Java 8：Lambda-Streams，按异常方法过滤

all

我在尝试 Java 8 的 Lambda 表达式时遇到问题。通常它可以正常工作，但现在我有了 throwIOException的方法。最好看看下面的代码：

class Bank{
    ....
    public Set<String> getActiveAccountNumbers() throws IOException {
        Stream<Account> s =  accounts.values().stream();
        s = s.filter(a -> a.isActive());
        Stream<String> ss = s.map(a -> a.getNumber());
        return ss.collect(Collectors.toSet());
    }
    ....
}

interface Account{
    ....
    boolean isActive() throws IOException;
    String getNumber() throws IOException;
    ....
}

问题是，它无法编译，因为我必须捕获 isActive- 和 getNumber-Methods 的可能异常。但即使我明确使用如下所示的 try-catch-Block，它仍然无法编译，因为我没有捕获异常。所以要么 JDK 中存在错误，要么我不知道如何捕获这些异常。

class Bank{
    ....
    //Doesn't compile either
    public Set<String> getActiveAccountNumbers() throws IOException {
        try{
            Stream<Account> s =  accounts.values().stream();
            s = s.filter(a -> a.isActive());
            Stream<String> ss = s.map(a -> a.getNumber());
            return ss.collect(Collectors.toSet());
        }catch(IOException ex){
        }
    }
    ....
}

我怎样才能让它工作？有人可以提示我正确的解决方案吗？

阅读 80

2022-04-06

共1个答案

小编典典

您必须在它转义 lambda之前捕获该异常：

s = s.filter(a -> {
    try {
        return a.isActive();
    } catch (IOException e) {
        throw new UncheckedIOException(e);
    }
});

考虑一个事实，即 lambda 不是在您编写它的地方评估的，而是在 JDK 类中的某个完全不相关的地方评估的。所以这将是抛出检查异常的地方，并且在那个地方它没有被声明。

您可以使用 lambda 的包装器来处理它，该包装器将已检查的异常转换为未检查的异常：

public static <T> T uncheckCall(Callable<T> callable) {
    try {
        return callable.call();
    } catch (RuntimeException e) {
        throw e;
    } catch (Exception e) {
        throw new RuntimeException(e);
    }
}

您的示例将写为

return s.filter(a -> uncheckCall(a::isActive))
        .map(Account::getNumber)
        .collect(toSet());

在我的项目中，我处理这个问题而不进行包装；相反，我使用一种有效地消除编译器检查异常的方法。不用说，这应该小心处理，项目中的每个人都必须知道，检查的异常可能会出现在未声明的地方。这是管道代码：

public static <T> T uncheckCall(Callable<T> callable) {
    try {
        return callable.call();
    } catch (Exception e) {
        return sneakyThrow(e);
    }
}

public static void uncheckRun(RunnableExc r) {
    try {
        r.run();
    } catch (Exception e) {
        sneakyThrow(e);
    }
}

public interface RunnableExc {
    void run() throws Exception;
}

@SuppressWarnings("unchecked")
private static <T extends Throwable> void sneakyThrow(Throwable t) throws T {
    throw (T) t;
}

IOException即使collect没有声明，您也可能会被扔在脸上。在大多数（但不是所有）现实生活中，无论如何，您都只想重新抛出异常，并将其作为一般故障处理。在所有这些情况下，清晰或正确不会丢失任何内容。请注意其他情况，您实际上希望在现场对异常做出反应。编译器不会让开发人员意识到那里有一个IOException要捕获的异常，如果您尝试捕获它，编译器实际上会抱怨，因为我们已经欺骗它相信不会抛出这样的异常。

2022-04-06