Java Stream流详解
Java Stream流是Java 8中引入的一种新的数据处理方式，它提供了一种高效、灵活的数据处理方式，能够帮助开发者更方便地处理大量数据。 Stream流不是一种数据结构，它也不是集合元素，而是一种算法和计算的方式，专门用于对集合对象进行各种便利、高效的聚合操作，或者大批量数据操作。
创建Stream流可以通过Collection.stream()函数创建一个Stream对象，也可以使用Stream接口的静态方法of获取数组对应的流。例如：
List<String> list = new ArrayList<>();
Stream<String> stream1 = list.stream();
String[] arr = {"张三", "李四", "王五"};
Stream<String> stream2 = Stream.of(arr);
Stream流提供了多种方法来处理数据，以下是一些常用的方法：
1. void forEach(Consumer<? super T> action)：该方法接收一个Consumer接口函数，会将每一个流元素交给该函数进行处理。此方法为终结方法，遍历后不能再调用Stream流的其他方法。
import java.util.stream.Stream;
public class Start {
public static void main(String[] args) {
String[] arr = {"张三", "李四", "王五"};
Stream<String> stream2 = Stream.of(arr);
stream2.forEach((name)->{
System.out.println(name);
});
}
}
2. Stream<T> filter(Predicate<? super T> predicate) ：将一个流转换成另一个子集流，此方法为终结方法。Predicate<T>函数式接口，抽象方法boolean test(T t)用来对指定数据进行判断是否满足条件。
import java.util.stream.Stream;
public class Start {
public static void main(String[] args) {
String[] arr = {"张三", "李四", "王五"};
Stream<String> stream2 = Stream.of(arr);
Stream<String> fil = stream2.filter((name) -> {
return name.startsWith("张");
});
fil.forEach(name->System.out.println(name));
}
}
3. Stream<R> map(Function<? super T, ? extends R> mapper)：将流中的元素映射到另一个流中。Function<T>函数式接口，可以将当前流中的T类型数据转换为另一种R类型的流。
import java.util.stream.Stream;
public class Start {
public static void main(String[] args) {
String[] arr = {"1", "2", "3"};
Stream<String> stream2 = Stream.of(arr);
Stream<Integer> map = stream2.map((string) -> {
return Integer.parseInt(string);
});
map.forEach(integer->System.out.println(integer));
}
}
4. long count() ：统计流中元素的个数，此方法为终结方法。
5. Stream<T> limit(long n)：用于截取流中的元素，只取用前n个元素，此方法是延迟方法，可以继续调用Stream流中的其他方法。
stream1.limit(2).forEach(name -> System.out.println(name));
Stream流还提供了其他许多方法，例如findAny()、findFirst()、reduce()等，能够满足开发者不同的需求。
Java Stream流是一种非常强大且灵活的数据处理方式，能够帮助开发者更方便地处理大量数据，并提高开发效率。
- 1
- 2
前往页