StreamAPI多次消費一個stream程式碼例項
阿新 • • 發佈:2020-04-02
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); }
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。