Java 8 Stream API 使用实例及陷阱

原创青旅半醒 2024-11-12 16:42 6阅读 0赞

Java8引入了 Stream API，它提供了对集合对象进行一系列操作的新方式，包括筛选、转换、聚合等。以下是一些使用 Stream API 的实例以及一些常见的陷阱。

### 使用实例1. **过滤（Filtering）**
 ```javaList<String> names = Arrays.asList("Alice", "Bob", "Charlie", "David");
List<String> startsWithB = names.stream()
.filter(name -> name.startsWith("B"))
.collect(Collectors.toList());
 ```2. **映射（Mapping）**
 ```javaList<Integer> numbers = Arrays.asList(1,2,3,4);
List<Integer> squares = numbers.stream()
.map(n -> n * n)
.collect(Collectors.toList());
 ```3. **聚合（Aggregating）**
 ```javaint sum = numbers.stream()
.reduce(0, (a, b) -> a + b);
 ```4. **排序（Sorting）**
 ```javaList<String> sortedNames = names.stream()
.sorted()
.collect(Collectors.toList());
 ```5. **组合操作**
 ```javaList<Integer> evenSquares = numbers.stream()
.filter(n -> n %2 ==0)
.map(n -> n * n)
.sorted()
.collect(Collectors.toList());
 ```6. **并行流（Parallel Streams）**
 ```javaList<Integer> parallelSquares = numbers.parallelStream()
.map(n -> n * n)
.collect(Collectors.toList());
 ```###常见陷阱1. **副作用**
- 在流操作中使用有副作用的操作（如 `System.out.println`）可能会导致不可预测的结果，因为流的元素可能以任意顺序被处理。
 ```java names.stream().forEach(System.out::println); //可能不会按预期顺序打印 ```2. **状态和非线程安全**
-流操作假设操作是无状态的和线程安全的。如果使用有状态的操作，可能会导致错误。
 ```java AtomicInteger count = new AtomicInteger();
 names.stream().forEach(name -> count.incrementAndGet()); //可能不会按预期工作 ```3. **并行流的陷阱**
-并行流可以提高性能，但也可能引入竞态条件和性能问题，特别是当操作不是线程安全的时候。
 ```javaList<Integer> parallelSquares = numbers.parallelStream()
.map(n -> n * n)
.collect(Collectors.toList());
 ```4. **无限流**
-无限流（如 `Stream.iterate`）需要明确的终止条件，否则会导致无限循环。
 ```javaStream.iterate(0, n -> n +1)
.limit(10)
.forEach(System.out::println); //需要限制，否则会无限循环 ```5. **中间操作和终止操作**
-流操作分为中间操作（返回一个新的流）和终止操作（返回一个最终结果或副作用）。过早地调用终止操作可能会导致流的链式操作被中断。
 ```javaList<Integer> squares = numbers.stream()
.map(n -> n * n)
.limit(2) //终止操作.collect(Collectors.toList()); //这里不能再链式调用 ```6. **资源管理**
- 使用 `try-with-resources`时，流操作应该在 try块中完成，以确保资源被正确关闭。
 ```java try (Stream<String> lines = Files.lines(Paths.get("file.txt"), StandardCharsets.UTF_8)) {
 long lineCount = lines.filter(line -> line.contains("error")).count();
 }
 ```使用 Stream API时，了解这些实例和陷阱可以帮助你更有效地编写代码，并避免常见的错误。