在流中处理空指针和抛出异常

Question

让我们考虑一个只包含一个Integer 属性的Parent 类。 我创建了 6 个父类对象和一个空变量。然后我将这些对象添加到列表中。

我想通过Integer属性的值来检索对应的对象。 我为此使用了 Java 8 Streams。

Predicate<Parent> predicate = e -> e.getId() == 100; // sample attribute value
result = list.stream().filter(predicate).collect(Collectors.toList());

但是我得到了NullPointerException，所以我编辑了代码：

list.stream().filter(h -> h!=null).filter(predicate).collect(Collectors.toList());

但是如果任何对象为空，我想抛出异常。如果列表中没有对象为空，那么我想从列表中检索相应的对象。

如何使用 Java 8 Streams 使用单个语句来实现这一点？

Answer 1

JB Nizet 的回答还可以，但它使用map 只是为了它的副作用，而不是用于映射操作，这有点奇怪。当您只对某些东西的副作用感兴趣时，可以使用一种方法，例如抛出异常：peek。

List<Parent> filtered = list.stream()
    .peek(Objects::requireNonNull)
    .filter(predicate)
    .collect(Collectors.toList());

如果您想要自己的异常，只需在其中放一个 lambda：

List<Parent> filtered = list.stream()
    .peek(p -> { if (p == null) throw new MyException(); })
    .filter(predicate)
    .collect(Collectors.toList());

---

检查的异常

如果检查了您的异常，您可以预先检查 null，如果您不介意遍历列表两次。这可能是您的最佳选择，但可能并不总是可行。

if (list.contains(null)) throw new MyCheckedException();

你也可以在你的流管道中抛出一个未经检查的异常，捕获它然后抛出一个经过检查的异常：

try {
    ...
        .peek(p -> { if (p == null) throw new MyException(); })
    ...
} catch (MyException exc) {
    throw new MyCheckedException();
}

---

偷袭

或者你可以走优雅但有争议的道路，使用偷偷摸摸的方法。

但要小心！这种技术绕过了检查异常系统，您应该知道自己在做什么。一定要声明周围的方法抛出MyCheckedException！如果你不这样做，编译器不会警告你，如果检查的异常出现在不应该出现的地方，它可能会导致奇怪的错误。

@SuppressWarnings("unchecked")
public <T extends Throwable> void throwSneakily(Throwable t) throws T {
    throw (T) t;
}

public void m() throws MyCheckedException {
    List<Parent> filtered = list.stream()
        .peek(p -> { if (p == null) throwSneakily(new MyCheckedException()); })
        .filter(predicate)
        .collect(Collectors.toList());
}

Answer 2

让我们从最简单的解决方案开始：

if(list.contains(null)) throw new MyException();
result = list.stream().filter(predicate).collect(Collectors.toList());

如果您怀疑该列表包含nulls，甚至有专门的异常类型来标记这种情况，那么预检查是最干净的解决方案。如果谓词更改为可以处理 nulls 的内容，或者当您使用可能在遇到后续 null 之前结束的短路流操作时，这可确保此类条件不会静默保留。

如果列表中出现null 仍然被认为是不应该发生的编程错误，但您只是想更改异常类型（我无法想象这样做的真正原因），您可能只是捕获并翻译异常：

try {
    result = list.stream().filter(predicate).collect(Collectors.toList());
}
catch(NullPointerException ex) {
    if(list.contains(null)) // ensure that we don’t hide another programming error
        throw new MyException();
    else throw ex;
}

在null 引用确实不发生的假设下有效。如前所述，如果您怀疑该列表包含null，您应该更喜欢预先检查。

Answer 3

::map vs ::peek

在生产代码中使用 Stream#map 并且永远不要使用 Stream#peek 方法。正如 Javadoc 所说，peek 是 mainly to support debugging ...where the stream implementation is able to optimize away..., the action will not be invoked for those elements. REF：javadoc

java.utils.Objects#requireNonNull

  list.stream()
      .map(Objects::requireNonNull)
      .filter(predicate)

这段代码清楚地将验证部分和过滤器部分分开。它将在异常调用堆栈中包含“requireNonNull”帧。虽然，按照 java.util 的设计，它会增加 NPE exceptionoin 类型。参考：javadoc。 SRC：openjdk

---

requireNonNull 带有静态消息

  list.stream()
      .map(item -> requireNonNull(item, "Null item in the list."))
      .filter(predicate)

导入静态 java.util.Objects.requireNonNull;

参考：javadoc。 SRC：openjdk

---

requireNonNull 与自定义消息供应商

  list.stream()
      .map(item -> requireNonNull(item, () -> "Expected non-null items. Was: " + list))
      .filter(predicate)

参考：javadoc。 SRC：openjdk

---

自定义验证器

  list.stream()
      .map(this::requireItemNonNull)
      .filter(predicate)
      ...


private Parent requireItemNonNull(Parent item) {
  if (null == item) throw new IllegalStateException("Expected: non null items. Was: " + this.list);
  return item;

---

全部验证

如果您只需要验证所有项目，请在最后使用收集器。例如。 toArray 作为流将实际迭代推迟到“收集”时间：

  list.stream()
      .map(this::validateItemNonNull)
      .toArray();

Answer 4

Function<Parent, Parent> throwingIdentity = p -> {
    if (p == null) {
        throw new MyException();
    }
    return p;
};

List<Parent> filtered = 
    list.stream()
        .map(throwingIdentity)
        .filter(predicate)
        .collect(Collectors.toList());