java|java jdk1.8新特性之Stream流
jdk8提供的Stream流能够方便操作集合、数组
java.util.stream包即是Stream流式计算的核心
Stream流的特点
- Stream自己不会存储元素
- Stream
不会改变源对象，相反，他们会返回一个持有结果的新Stream - Stream 操作总是延迟执行的。这意味着他们会等到需要结果的时候才执行
①、从数据源中获得流 ==> 一个数据源(数组、List)
arrayList.stream()
②、中间操作==>处理数据源数据
.map(e -> e.get("a"))
③、终止操作==>执行中间操作链，产生结果
.collect(Collectors.toList());
获得流
普通流stream()
import java.util.Arrays;
import java.util.List;
public class Test {
public static void main(String[] args) {
List strings = Arrays.asList("abc", "", "bc", "efg", "abcd", "", "jkl");
// 获取空字符串的数量
int count = (int) strings.stream().filter(string -> string.isEmpty()).count();
System.out.println(count);
}
}
并行流 parallelStream() parallelStream 是流并行处理程序的代替方法。以下实例我们使用parallelStream 来输出空字符串的数量：
import java.util.Arrays;
import java.util.List;
public class Test {
public static void main(String[] args) {
List strings = Arrays.asList("abc", "", "bc", "efg", "abcd", "", "jkl");
// 获取空字符串的数量
int count = (int) strings.parallelStream().filter(string -> string.isEmpty()).count();
System.out.println(count);
}
}
中间操作
文章图片
image.png
文章图片
image.png
文章图片
image.png forEach Stream 提供了新的方法 'forEach' 来迭代流中的每个数据。以下代码片段使用forEach 输出了10个随机数：
import java.util.Random;
public class Test {public static void main(String[] args) {
Random random = new Random();
random.ints().limit(10).forEach(System.out::println);
}
}
map 【java|java jdk1.8新特性之Stream流】map 方法用于映射每个元素到对应的结果，以下代码片段使用 map 输出了元素对应的平方数：
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
public class Test {public static void main(String[] args) {
List numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);
// 获取对应的平方数
List squaresList = numbers.stream().map(i -> i * i).collect(Collectors.toList());
squaresList.forEach(System.out::println);
}
}
filter filter 方法用于通过设置条件过滤出元素。以下代码片段使用filter 方法过滤出空字符串，然后统计数量：
import org.apache.commons.lang3.StringUtils;
import java.util.Arrays;
import java.util.List;
public class Test {public static void main(String[] args) {
Liststrings = Arrays.asList("abc", " ", null,"bc", "efg", "abcd"," ", "jkl");
// 获取空字符串的数量
int count = (int) strings.stream().filter(string -> StringUtils.isBlank(string)).count();
System.out.println(count);
}
}
Limit limit 方法用于获取指定数量的流。以下代码片段使用 limit 方法打印出 10 条数据：
import java.util.Random;
public class Test {
public static void main(String[] args) {
Random random = new Random();
random.ints().limit(10).forEach(System.out::println);
}
}
sorted sorted 方法用于对流进行排序。以下代码片段使用 sorted 方法对输出的 10 个随机数进行排序：
import java.util.Random;
public class Test {
public static void main(String[] args) {
Random random = new Random();
random.ints().limit(10).sorted().forEach(System.out::println);
}
}
终止操作
Collectors 转化为集合、聚合元素、字符串 Collectors 类实现了很多归约操作，例如将流转换成集合和聚合元素。Collectors可用于返回列表或字符串：
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
public class Test {
public static void main(String[] args) {
List strings = Arrays.asList("abc", "", "bc", "efg", "abcd", "", "jkl");
List filtered = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.toList());
System.out.println("筛选列表: " + filtered);
String mergedString = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.joining(", "));
System.out.println("合并字符串: " + mergedString);
}
}
summaryStatistics 统计 另外，一些产生统计结果的收集器也非常有用。它们主要用于int、double、long等基本类型上，它们可以用来产生类似如下的统计结果。
import java.util.Arrays;
import java.util.IntSummaryStatistics;
import java.util.List;
import java.util.stream.Collectors;
public class Test {
public static void main(String[] args) {
List numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);
IntSummaryStatistics stats = numbers.stream().mapToInt((x) -> x).summaryStatistics();
System.out.println("列表中最大的数 : " + stats.getMax());
System.out.println("列表中最小的数 : " + stats.getMin());
System.out.println("所有数之和 : " + stats.getSum());
System.out.println("平均数 : " + stats.getAverage());
}
}
Stream流使用实战
从List