Java8中Stream使用的一個注意事項

更新時間：2017年11月13日 11:47:41 作者：阿杜

最近在工作中發(fā)現(xiàn)了對于集合操作轉(zhuǎn)換的神器，java8新特性 stream，但在使用中遇到了一個非常重要的注意點，所以這篇文章主要給大家介紹了關(guān)于Java8中Stream使用過程中的一個注意事項，需要的朋友可以參考借鑒，下面隨著小編來一起學習學習吧。

Stream簡介

我們先來看看Java里面是怎么定義Stream的：

A sequence of elements supporting sequential and parallel aggregate operations.

我們來解讀一下上面的那句話：

Stream是元素的集合，這點讓Stream看起來用些類似Iterator；
可以支持順序和并行的對原Stream進行匯聚的操作；

大家可以把Stream當成一個高級版本的Iterator。原始版本的Iterator，用戶只能一個一個的遍歷元素并對其執(zhí)行某些操作；高級版本的Stream，用戶只要給出需要對其包含的元素執(zhí)行什么操作，比如“過濾掉長度大于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的個數(shù)。這段代碼雖然很簡短，但是卻是一個很好的入門級別的例子來體現(xiàn)如何使用Stream，正所謂“麻雀雖小五臟俱全”。

引子

今天下午遇到一個NPE，如下圖所示

跟了下源碼，最后跟到ReferencePipeline#193行，應該是調(diào)用apply的時候，入?yún)為null，從而觸發(fā)了空指針異常。

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

最佳實踐