一尘不染

Java 8:Lambda-Streams,按方法进行过滤(异常)

java

在尝试Java 8的Lambda表达式时遇到问题。通常它可以正常工作,但是现在我有抛出IOException的方法。最好查看以下代码:

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,它仍然无法编译,因为我没有捕获到Exception。因此,要么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){
        }
    }
    ....
}

我该如何运作?有人可以提示我正确的解决方案吗?


阅读 543

收藏
2020-03-15

共1个答案

一尘不染

你必须先捕获异常,然后才能转出lambda:

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

考虑以下事实:在JDK类中,lambda不在你编写的位置评估,而是在某些完全不相关的位置评估。这样便可以抛出该检查异常,并且在该位置不声明该异常。

你可以通过使用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陷阱,实际上,如果你尝试捕获它,编译器实际上会抱怨,因为我们欺骗了它以为不会抛出此类异常。

2020-03-15