延迟执行与不可变，系统讲解JavaStream数据处理_【快资讯】

转换流操作：例如filter和map方法，将一个Stream转换成另一个Stream，返回值都是Stream。

终结流操作：例如count和collect方法，将一个Stream汇总为我们需要的结果，返回值都不是Stream。

无状态：即此方法的执行无需依赖前面方法执行的结果集。

有状态：即此方法的执行需要依赖前面方法执行的结果集。

ListInteger list = List.of(1, 2, 3); ListInteger filterList = new ArrayList();
for (Integer i : list) { if (i 2) { filterList.add(i); } }
System.out.println(filterList);

ListInteger list = List.of(1, 2, 3); ListInteger filterList = new ArrayList();
for (Integer i : list) { if (i 2 i 10 (i % 2 == 0)) { filterList.add(i); } }
System.out.println(filterList);

ListInteger list = List.of(1, 2, 3).stream() .filter(i - i 2) .filter(i - i
10) .filter(i - i % 2 == 0) .collect(toList());

由于每次Stream操作都会生成一个新的Stream，所以Stream是不可变的，就像String。

在Stream中只保存原集合的引用，所以在进行一些会修改元素的操作时，是通过原元素生成一份新的新元素，所以Stream 的任何操作都不会影响到原对象。

List.of(1, 2, 3).stream() .filter(i - i 2) .peek(System.out::println);

List.of(1, 2, 3).stream() .filter(i - i 2) .peek(System.out::println)
.count();

使用Steam接口创建

通过集合类库创建

public static Stream of(T… values) { return Arrays.stream(values); }

StreamInteger integerStream = Stream.of(1, 2, 3); StreamDouble doubleStream =
Stream.of(1.1d, 2.2d, 3.3d); StreamString stringStream = Stream.of("1",
"2", "3");

StreamInteger integerStream = Stream.of(1, 2, 3);

StreamObject empty = Stream.empty();

public static Stream generate(Supplier? extends T s) {
Objects.requireNonNull(s); return StreamSupport.stream( new
StreamSpliterators.InfiniteSupplyingSpliterator.OfRef(Long.MAX_VALUE, s),
false); }

StreamString generate = Stream.generate(() - "Supplier"); StreamInteger
generateInteger = Stream.generate(() -

StreamInteger integerStreamList = List.of(1, 2, 3).stream(); StreamString
stringStreamList = List.of("1", "2", "3").stream();

StreamInteger listStream = List.of(1, 2, 3).stream(); StreamInteger setStream
= Set.of(1, 2, 3).stream();

default Stream stream() { return StreamSupport.stream(spliterator(), false); }

StreamInteger integerParallelStream = Stream.of(1, 2, 3).parallel();
StreamString stringParallelStream = Stream.of("1", "2", "3").parallel();
StreamInteger integerParallelStreamList = List.of(1, 2, 3).parallelStream();
StreamString stringParallelStreamList = List.of("1", "2",
"3").parallelStream();

default Stream stream() { return StreamSupport.stream(spliterator(), false); }
default Stream parallelStream() { return StreamSupport.stream(spliterator(),
true); }

Stream.of(1, 2, 3).parallel().sequential();

StreamInteger concat = Stream .concat(Stream.of(1, 2, 3), Stream.of(4, 5, 6));

StreamInteger integerStream = Stream.of(1, 2, 3); StreamString stringStream =
Stream.of("1", "2", "3"); Stream? extends Serializable stream =
Stream.concat(integerStream, stringStream);