Java 8 中 Stream API 的引入改变了数据操作和处理的格局。在此基础上，Java 9 通过引入一系列强大的改进进一步提升了 Stream API。这些增强功能旨在增强代码可读性、效率、错误处理和整体性能。在本文中，我们将踏上探索 Java 9 Stream API 显着增强功能的旅程，并通过说明性示例来实现这些改进。
1. 流 takeWhile() 和 dropWhile()：
Java 9 向 Stream API 引入了两个突破性的方法：takeWhile() 和 dropWhile()。这些方法使开发人员能够对流处理进行精确控制，从而能够根据特定条件提取或省略元素。
import java.util.*;
import java.util.stream.Collectors;
public class StreamDemo {
public static void main(String[] args) {
// Create a list of integers from 1 to 10
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
// 使用 takeWhile 从列表中使用流过滤偶数
// 只要条件（n % 2 == 0）为真，takeWhile 方法就会从流中获取元素 ；
List<Integer> evenNumbers = numbers.stream()
.takeWhile(n -> n % 2 == 0)
.collect(Collectors.toList());
// Print the list of even numbers
System.out.println("Even Numbers: " + evenNumbers);
}
}
|
2. 可空流：
Java 9 中引入的 Stream.ofNullable() 方法是一个改变游戏规则的方法，用于处理可为 null 值，而无需显式 null 检查的负担。
import java.util.stream.Stream;
public class StreamDemo {
public static void main(String[] args) {
String username = getUsername(); // Might return null
Stream<String> usernameStream = Stream.ofNullable(username);
usernameStream.forEach(System.out::println); // No output if username is null
}
private static String getUsername() {
// Simulating the retrieval of a username
return "john_doe";
}
}
|
3. 使用谓词进行迭代：
Java 9 通过提供一个谓词来增强 iterate 方法，该谓词指示迭代何时应停止。这一改进消除了在循环内进行显式手动检查的需要。
import java.util.stream.Stream;
public class StreamDemo {
public static void main(String[] args) {
Stream.iterate(1, n -> n <= 10, n -> n * 2)
.forEach(System.out::println);
}
}
|
4. 可选流：
随着 Java 9 的出现，stream() 方法使开发人员能够从可选值创建流，从而简化使用可选值时的处理。
import java.util.Optional;
public class StreamDemo {
public static void main(String[] args) {
Optional<String> optionalValue = Optional.of("Hello, Java 9!");
optionalValue.stream()
.map(String::toUpperCase)
.forEach(System.out::println);
}
}
|
5. 增强的流工厂方法：
Java 9 引入了更简化的方法来从不同的数据源（包括数组、迭代器和 Spliterator 实例）生成流。
import java.util.Arrays;
import java.util.stream.Stream;
public class StreamDemo {
public static void main(String[] args) {
String[] words = {"Java", "Stream", "API", "Enhancements"};
Stream<String> wordStream = Arrays.stream(words);
wordStream.forEach(System.out::println);
}
}
|
6. 可选的增强流 API：
Java 9 扩展了可用于可选实例的 Stream API 的全部功能。ifPresentOrElse 方法增强了处理可选值的代码的表现力。
import java.util.Optional;
public class StreamDemo {
public static void main(String[] args) {
Optional<Integer> number = Optional.of(42);
number.ifPresentOrElse(
n -> System.out.println("Number: " + n),
() -> System.out.println("No number present")
);
}
}
|
7. 使用累加器进行流迭代：
Java 9 引入了迭代方法的新变体，允许累加器函数。这简化了使用初始值和累加器函数构建序列的过程。
import java.util.stream.Stream;
public class StreamDemo {
public static void main(String[] args) {
Stream.iterate(1, n -> n <= 10, n -> n + 1)
.forEach(System.out::println);
}
}
|
8. 改进的流性能：
Java 9 付出了额外的努力来优化 Stream API 的性能，从而缩短了流操作的执行时间。这些增强功能使流处理显着更加高效，尤其是在处理大量数据集时。