1. 程式人生 > 程式設計 >StreamAPI多次消費一個stream程式碼例項

StreamAPI多次消費一個stream程式碼例項

StreamAPI中的stream不能被重複消費,一旦它被使用,stream就被關閉了,別的地方再消費它就會拋IllegalStateException:stream has already been operated upon or closed。

比如下面的程式碼中,stream被消費了兩次,第二次消費時將會拋異常:

@Test
public void statistics() {
  IntStream range = IntStream.range(0,12);

  OptionalInt min = range.min(); //第一次消費正常
  System.out.println(min);

  long count = range.count(); //第二次消費將報錯
  System.out.println(count);
}

如何實在需要多次消費呢,通過Supplier來生產stream,每次呼叫supplier.get()獲取一個嶄新的stream物件,雖然物件是新的,但是每個stream中的資料是相同的,間接地實現了重複消費的語義:

@Test
public void statistics0() {
  Supplier<IntStream> supplier= () -> IntStream.range(0,12);

  OptionalInt min = supplier.get().min(); //第一次消費正常
  System.out.println(min);

  long count = supplier.get().count(); //第二次消費正常
  System.out.println(count);
}

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。