Java8中Stream使用的一个注意事项

来源:爱站网时间:2020-02-10编辑:网友分享
java8中并行流和流的区别在于它们支持并行执行,提高了程序的运行效率,如果使用不当,可能会出现线程安全问题,下面爱站技术频道为大家介绍Java8中Stream使用的一个注意事项吧!

java8中并行流和流的区别在于它们支持并行执行,提高了程序的运行效率,如果使用不当,可能会出现线程安全问题,下面爱站技术频道为大家介绍Java8中Stream使用的一个注意事项吧!

Stream简介

我们先来看看Java里面是怎么定义Stream的:

A sequence of elements supporting sequential and parallel aggregate operations.

我们来解读一下上面的那句话:

  • Stream是元素的集合,这点让Stream看起来用些类似Iterator;
  • 可以支持顺序和并行的对原Stream进行汇聚的操作;

大家可以把Stream当成一个高级版本的Iterator。原始版本的Iterator,用户只能一个一个的遍历元素并对其执行某些操作;高级版本的Stream,用户只要给出需要对其包含的元素执行什么操作,比如“过滤掉长度大于10的字符串”、“获取每个字符串的首字母”等,具体这些操作如何应用到每个元素上,就给Stream就好了!(这个秘籍,一般人我不告诉他:))大家看完这些可能对Stream还没有一个直观的认识,莫急,咱们来段代码。

//Lists是Guava中的一个工具类
List<Integer> nums = Lists.newArrayList(1,null,3,4,null,6);
nums.stream().filter(num -> num != null).count();

上面这段代码是获取一个List中,元素不为null的个数。这段代码虽然很简短,但是却是一个很好的入门级别的例子来体现如何使用Stream,正所谓“麻雀虽小五脏俱全”。

引子

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

跟了下源码,最后跟到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;
}

最佳实践

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

以上就是爱站技术频道小编介绍的Java8中Stream使用的一个注意事项,需要学习的朋友要着手准备了哦。

上一篇:Java中的main函数的详细介绍

下一篇:浅谈Java堆外内存之突破JVM枷锁

您可能感兴趣的文章

相关阅读

热门软件源码

最新软件源码下载