Java8中Stream使用的一個(gè)注意事項(xiàng)

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

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

Stream簡(jiǎn)介

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

A sequence of elements supporting sequential and parallel aggregate operations.

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

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

大家可以把Stream當(dāng)成一個(gè)高級(jí)版本的Iterator。原始版本的Iterator，用戶只能一個(gè)一個(gè)的遍歷元素并對(duì)其執(zhí)行某些操作；高級(jí)版本的Stream，用戶只要給出需要對(duì)其包含的元素執(zhí)行什么操作，比如“過濾掉長(zhǎng)度大于10的字符串”、“獲取每個(gè)字符串的首字母”等，具體這些操作如何應(yīng)用到每個(gè)元素上，就給Stream就好了?。ㄟ@個(gè)秘籍，一般人我不告訴他：））大家看完這些可能對(duì)Stream還沒有一個(gè)直觀的認(rèn)識(shí)，莫急，咱們來段代碼。

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

上面這段代碼是獲取一個(gè)List中，元素不為null的個(gè)數(shù)。這段代碼雖然很簡(jiǎn)短，但是卻是一個(gè)很好的入門級(jí)別的例子來體現(xiàn)如何使用Stream，正所謂“麻雀雖小五臟俱全”。

引子

今天下午遇到一個(gè)NPE，如下圖所示

跟了下源碼，最后跟到ReferencePipeline#193行，應(yīng)該是調(diào)用apply的時(shí)候，入?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));
 }
 };
 }
 };
}

為了驗(yàn)證我的想法，我寫了如下的測(cè)試?yán)樱?/p>

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

最佳實(shí)踐