Java 8中Stream使用的一个小点

引子

今天下午遇到一个NPE,如下图所示

image.png

跟了下源码,最后跟到ReferencePipeline#193行,应该是调用apply的时候,入参u为null,从而触发了空指针异常。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
@Override
@SuppressWarnings("unchecked")
public final <R> Stream<R> map(Function<? super P_OUT, ? extends R> mapper) {
Objects.requireNonNull(mapper);
return new StatelessOp<P_OUT, R>(this, StreamShape.REFERENCE,
StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
@Override
Sink<P_OUT> opWrapSink(int flags, Sink<R> sink) {
return new Sink.ChainedReference<P_OUT, R>(sink) {
@Override
public void accept(P_OUT u) {
downstream.accept(mapper.apply(u));
}
};
}
};
}

为了验证我的想法,我写了如下的测试例子:

1
2
3
4
5
6
7
8
public static void main(String[] args) {
List<Long> res = Arrays.asList(1L, 2L, null);
res.stream().map(UserReadServiceImpl::get).collect(Collectors.toList());
}

public static Long get(long userId) {
return userId;
}

最佳实践

  1. 在Streams开始和结束之前,都需要避免处理null值,使用filter可以过滤掉;
  2. 不要滥用Streams,因为我发现Stream有时候会让代码变得更难以阅读;
  3. 针对Collections的迭代处理,可以多用Stream处理;
  4. 要谨慎使用Parallel Streams,性能不一定比普通的loop要好;
  5. 最后,对外暴露API的入参检查需要更全面;

参考资料

  1. Java SE 8最佳实践](https://www.jfokus.se/jfokus17/preso/Java-SE-8-best-practices.pdf)
  2. 流处理线:ReferencePipeline](http://download.java.net/lambda/b72/docs/api/java/util/stream/ReferencePipeline.html)