Java中的流（Stream）操作：理解与实践案例

原创 ╰半橙微兮° 2024-11-07 06:48 8阅读 0赞

Java中的流（Stream）是Java8引入的一个重要特性，它提供了对集合对象进行一系列操作的新方式，包括筛选、转换、聚合等。流操作可以是并行的，这意味着它们可以利用多核处理器来加速处理，并且可以以声明式的方式写出复杂的操作。

###理解流（Stream）

1. **流不是数据结构**：流不存储元素，而是代表对数据源的一系列操作。
2. **流是懒加载的**：操作不会立即执行，而是在需要结果时才执行。
3. **流是一次性的**：一旦流被操作并产生结果，它就被认为是被消费了，不能再次使用。
4. **流可以是并行的**：可以通过`parallelStream()`方法将流转换为并行流，以利用多核处理器。

###流操作的三个阶段1. **创建流**：可以通过集合的`stream()`方法、数组的`Arrays.stream()`方法或者Stream类的静态方法（如`Stream.of()`）来创建流。
2. **中间操作**：可以进行一系列操作，如`filter()`、`map()`、`flatMap()`、`limit()`等，这些操作会返回一个新的流。
3. **终止操作**：最终需要一个终止操作来产生结果，如`forEach()`、`collect()`、`reduce()`、`allMatch()`等。

### 实践案例####案例1：筛选和计数```javaList<String> words = Arrays.asList("apple", "banana", "", "cherry", "strawberry", "", "melon");
long emptyCount = words.stream()
.filter(String::isEmpty)
.count();
System.out.println("Empty strings: " + emptyCount);
```####案例2：转换和收集```javaList<String> words = Arrays.asList("apple", "banana", "cherry", "strawberry", "melon");
Map<String, Long> wordCount = words.stream()
.collect(Collectors.groupingBy(Function.identity(), Collectors.counting()));
System.out.println(wordCount);
```####案例3：排序```javaList<String> words = Arrays.asList("apple", "banana", "cherry", "strawberry", "melon");
List<String> sortedWords = words.stream()
.sorted()
.collect(Collectors.toList());
System.out.println(sortedWords);
```####案例4：并行流```javaList<Integer> numbers = IntStream.rangeClosed(1,1000).boxed().collect(Collectors.toList());
long sum = numbers.parallelStream()
.filter(n -> n %2 ==0)
.mapToInt(Integer::intValue)
.sum();
System.out.println("Sum of even numbers: " + sum);
```这些案例展示了流操作的基本用法，包括筛选、转换、聚合和并行处理。流提供了一种强大且表达性强的方式来处理集合数据。