Java 8中Stream使用的一个小点

一、引子

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

• image.png

之前没仔细查过Stream的源码，也没有深究背后的原因，今天跟了下源码，最后跟到ReferencePipeline#193行，应该是调用apply的时候，入参u为null，从而触发了空指针异常。

    @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));
                    }
                };
            }
        };
    }

为了验证我的想法，我写了如下的测试例子：

    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最佳实践
2. 流处理线：ReferencePipeline