flatMap(Function3 查找和匹配
另一个常见的数据处理套路是看看数据集中的某些元素是否匹配一个给定的属性。Stream
API通过 allMatch 、 anyMatch 、 noneMatch 、 findFirst 和 findAny 方法提供了这样的工具
3.1 检查谓词是否至少匹配一个元素
anyMatch()
@Test
public void test12() {
boolean b = menu.stream().anyMatch(Dish::isVegetarian);
if(b){
System.out.println("有素菜!");
}
}anyMatch 方法可以回答“流中是否有一个元素能匹配给定的谓词”。
anyMatch 方法返回一个 boolean ，因此是一个终端操作.
3.2 检查谓词是否匹配所有元素
allMatch()
@Test
public void test13() {
boolean b = menu.stream()
.allMatch(dish -> dish.getCalories() < 1000);
if (b) {
System.out.println("没有高热量事物,吃!");
}
}noneMatch()
和 allMatch 相对的是 noneMatch 。它可以确保流中没有任何元素与给定的谓词匹配
@Test
public void test14() {
boolean b = menu.stream().noneMatch(dish -> {
return dish.getCalories() > 1000;
});
if (b) {
System.out.println("没有高热量事物,吃!");
}
}短路求值
有些操作不需要处理整个流就能得到结果。例如，假设你需要对一个用 and 连起来的大布
尔表达式求值。不管表达式有多长，你只需找到一个表达式为 false ，就可以推断整个表达式
将返回 false ，所以用不着计算整个表达式。这就是 短路。
对于流而言，某些操作（例如 allMatch 、 anyMatch 、 noneMatch 、 findFirst 和 findAny ）
不用处理整个流就能得到结果。只要找到一个元素，就可以有结果了。同样， limit 也是一个
短路操作：它只需要创建一个给定大小的流，而用不着处理流中所有的元素。在碰到无限大小
的流的时候，这种操作就有用了：它们可以把无限流变成有限流.
3.3 查找元素
findAny()
@Test
public void test15() {
Optional any = menu.stream()
.filter(dish -> dish.getCalories() == 450)
.findAny();
System.out.println(any);
any.ifPresent(dish -> {
System.out.println(dish.getCalories());
});
}结果:
Optional[Dish{name='salmon', vegetarian=false, calories=450, type=FISH}]
450可以看到 findAny() 返回一个 Optional 类型的值,
Optional 简介
Optional 类（ java.util.Optional ）是一个容器类，代表一个值存在或不存在。在
上面的代码中， findAny 可能什么元素都没找到。Java 8的库设计人员引入了 Optional ，这
样就不用返回众所周知容易出问题的 null 了。
Optional 里面几种可以迫使你显式地检查值是否存在或处理值不存在的情形的方法也不错。
* isPresent() 将在 Optional 包含值的时候返回 true , 否则返回 false 。
* ifPresent(Consumer block) 会在值存在的时候执行给定的代码块。我们在第3章
介绍了 Consumer 函数式接口；它让你传递一个接收 T 类型参数，并返回 void 的Lambda
表达式。
* T get() 会在值存在时返回值，否则抛出一个 NoSuchElement 异常。
* T orElse(T other) 会在值存在时返回值，否则返回一个默认值。
3.4 查找第一个元素
FindFirst()
用来找到流中的第一个元素,它的工作方式类似于 findany
@Test
public void test16() {
List someNumbers = Arrays.asList(1, 2, 3, 4, 5);
Optional firstSquareDivisibleByThree =
someNumbers.stream()
.map(x -> x * x)
.filter(x -> x % 3 == 0)
.findFirst(); // 9结果:
Optional[9]
何时使用 findFirst 和 findAny????
**你可能会想，为什么会同时有 findFirst 和 findAny 呢？答案是并行。找到第一个元素
在并行上限制更多。如果你不关心返回的元素是哪个，请使用 findAny ，因为它在使用并行流
时限制较少。**
4 归约
到目前为止,你所见到的终端操作都返回一个boolean(allMatch之类),void(forEach),或Optional对象(findOny等).你也见过了可以用collect来将流中的元素合成一个List.
接下来,你将会看到如何把一个流中的元素组合起来,比如“计算菜单中的总卡路里”或“菜单中卡路里最高的菜是哪一个”.
此类查询需要将流反复组合起来,得到一个值比如Integer,这样的查询可被归类为 归约操作.
用函数式编程的术语来说,这称为折叠(fold),因为你可以讲这个流看作一张长长的纸(你的流),反复折叠成一个小方块,这就是折叠操作的结果.
4.1 元素求和
reduce()
先看使用java8之前的 for-each 的做法
int sum = 0;
for (int
numbers中的每一个元素都使用加法运算反复迭代来得到结果.通过反复使用加法,你把一个数字列表归约成了一个数字.
要是还能把所有的数字相乘，而不必去复制粘贴这段代码，岂不是很好？这正是 reduce 操
作的用武之地，它对这种重复应用的模式做了抽象。你可以像下面这样对流中所有的元素求和
@Test
public void test17() {
List numbers = Arrays.asList(1, 2, 3, 4, 5);
Integer reduce = numbers.stream().reduce(0, (a, b) -> a + b);
System.out.println(reduce);//15reduce 接受两个参数：
* 一个初始值，这里是0
* 一个 BinaryOperator 来将两个元素结合起来产生一个新值，这里我们用的是
lambda (a, b) -> a + b
上面的操作效果我们可以理解为:把初始值和后面的函数每一次计算的结果相加求和.
@Test
public void test17() {
List numbers = Arrays.asList(1, 2, 3, 4, 5);
Integer reduce = numbers.stream()
.reduce(1, (a,b)->a*b);
System.out.println(reduce);//120这个操作效果我们可以理解为:把初始值和后面的函数每一次计算的结果相乘.
通过这两个例子我们可以看到:reduce两个参数的运算方式取决于后面Lambda的运算方式
Lambda反复结合每个元素，直到流被归约成一个值.
在java8中Integer类多了几个静态方法,
/**
* Adds two integers together as per the + operator.
*
* @param a the first operand
* @param b the second operand
* @return the sum of {@code a} and {@code b}
* @see java.util.function.BinaryOperator
* @since
public static int sum(int a, int b) {
return a + b;
}
/**
* Returns the greater of two {@code int} values
* as if by calling {@link Math#max(int, int) Math.max}.
*
* @param a the first operand
* @param b the second operand
* @return the greater of {@code a} and {@code b}
* @see java.util.function.BinaryOperator
* @since
public static int max(int a, int b) {
return Math.max(a, b);
}
/**
* Returns the smaller of two {@code int} values
* as if by calling {@link Math#min(int, int) Math.min}.
*
* @param a the first operand
* @param b the second operand
* @return the smaller of {@code a} and {@code b}
* @see java.util.function.BinaryOperator
* @since
public static int min(int a, int b) {
return这不正好可以让我们结合Lambda表达式吗!(可能java8的设计者特意增加了这几个操作适应Lambda编程需要),总之我们代码看起来可以更简洁
@Test
public void test17() {
List numbers = Arrays.asList(1, 2, 3, 4, 5);
Integer reduce = numbers.stream()
.reduce(0, Integer::sum);
System.out.println(reduce);
}无初始值
reduce还有一个重载的载体,它不接受初始值,但是会返回一个 Optional 对象.
@Test
public void test18() {
List numbers = Arrays.asList(1, 2, 3, 4, 5);
Optional optional = numbers.stream()
.reduce(Integer::sum);
System.out.println(optional);
}为什么它返回一个 Optional 呢？考虑到流中没有值的情况,reduce操作便无法返回其和,因为没有初始值.这就是为什么结果被包裹在一个Optional对象里,以表明结果可能不存在.
4.2 求最大值和最小值
@Test
public void test19() {
List numbers = Arrays.asList(1, 2, 3, 4, 5);
Optional max = numbers.stream()
.reduce(Integer::max);
Optional min = numbers.stream().reduce(Integer::min);
System.out.println("max="+max+",min="+min);
}给定两个元素能够返回最大值的Lambda,redce会考虑流中的新值和下一个元素,并产生一个新的最大值,直到整个流消耗完.
归约方法的优势与并行化
相比于java8之前的迭代求和,我们使用reduce的好处在于,这里的迭代被内部迭代抽象掉了,这让内部迭代可以选择并行执行reduce操作. 而迭代求和的例子要更新共享变量sum,这不是那么容易并行化的.
如果你加入了同步,可能会发现线程竞争抵消掉了并行本应该带来的性能提升.
这种计算的并行化需要另一种方法:将输入分块,再分块求和,最后再合并起来.
这正式reduce所提供的,使用流来对所有的元素并行求和时，你的代码几乎不用修改： stream() 换成了 parallelStream().
付诸实践
我们先会议一下目前为止讲到的所有流操作
public class TradeTest
Trader raoul = new Trader("Raoul", "Cambridge");
Trader mario = new Trader("Mario", "Milan");
Trader alan = new Trader("Alan", "Cambridge");
Trader brian = new Trader("Brian", "Cambridge");
List transactions = Arrays.asList(
new Transaction(brian, 2011, 300),
new Transaction(raoul, 2012, 1000),
new Transaction(raoul, 2011, 400),
new Transaction(mario, 2012, 710),
new Transaction(mario, 2012, 700),
new Transaction(alan, 2012, 950)
);
//(1) 找出2011年发生的所有交易，并按交易额排序（从低到高）。
@Test
public void test1(){
List list = transactions.stream()
.filter(transaction -> transaction.getYear() == 2011)
.sorted(Comparator.comparing(Transaction::getValue))
.collect(toList());
System.out.println(list);
}
//(2) 交易员都在哪些不同的城市工作过？
@Test
public void test2(){
List list = transactions.stream()
.map(Transaction::getTrader)
.map(Trader::getCity)
.distinct()
.collect(toList());
System.out.println(list);
List list1 = transactions.stream()
.map(transaction -> transaction.getTrader().getCity())
.distinct()
.collect(toList());
System.out.println(list1);
}
//(3) 查找所有来自于剑桥的交易员，并按姓名排序。
@Test
public void test3(){
List list = transactions.stream()
.map(Transaction::getTrader)
.filter(trader -> trader.getCity().equals("Cambridge"))
.sorted(Comparator.comparing(Trader::getName))
.collect(toList());
System.out.println(list);
List list1 = transactions.stream()
.filter(transaction -> transaction.getTrader().getCity().equals("Cambridge"))
.map(Transaction::getTrader)
.sorted(Comparator.comparing(Trader::getName))
.collect(toList());
System.out.println(list1);
}
//(4) 返回所有交易员的姓名字符串，按字母顺序排序。
@Test
public void test4(){
List list = transactions.stream()
.map(Transaction::getTrader)
.map(Trader::getName)
.sorted((s1, s2) -> s1.compareTo(s2))
//.distinct()
.collect(toList());
System.out.println(list);
List list1 = transactions.stream()
.map(transaction -> transaction.getTrader().getName())
.sorted((s1, s2) -> s1.compareTo(s2))
.collect(toList());
System.out.println(list1);
}
//(5) 有没有交易员是在米兰工作的？
@Test
public void test5(){
boolean b = transactions.stream()
.map(Transaction::getTrader)
.anyMatch(trader -> trader.getCity().equals("Milan"));
System.out.println(" 有没有交易员是在米兰工作的？="+b);
boolean b1 = transactions.stream()
.anyMatch(transaction -> transaction.getTrader().getCity().equals("Milan"));
System.out.println(" 有没有交易员是在米兰工作的？="+b1);
}
//(6) 打印生活在剑桥的交易员的所有交易额。
@Test
public void test6(){
List list = transactions.stream()
.filter(transaction -> transaction.getTrader().getCity().equals("Cambridge"))
.map(Transaction::getValue)
.collect(toList());
System.out.println(list);
}
// (7) 所有交易中，最高的交易额是多少？
@Test
public void test7(){
Optional reduce = transactions.stream()
.map(Transaction::getValue)
.reduce(Integer::max);
System.out.println(reduce);
}
//(8) 找到交易额最小的交易。
@Test
public void test8(){
Optional reduce = transactions.stream()
.map(Transaction::getValue)
.reduce(Integer::min);
System.out.println(reduce);
}
//(9) 计算交易总额
@Test
public void test9(){
Integer reduce = transactions.stream()
.map(transaction -> transaction.getValue())
.reduce(0, Integer::sum);
System.out.println(reduce);
}
}5 数值流
我们先看下这段代码有什么问题
//(9) 计算交易总额
@Test
public void test9(){
Integer reduce = transactions.stream()
.map(transaction -> transaction.getValue())
.reduce(0, Integer::sum);
System.out.println(reduce);
}这段代码的问题是，它有一个暗含的装箱成本。每个 Integer 都必须拆箱成一个原始类型，
再进行求和
Java 8引入了三个原始类型特化流接口来解决这个问题：
5.1 原始类型流特化
IntStream,DoubleStream,LongStream 分别将流中的元素特化为 int ,double, long ,从而避免了暗含的装箱成本.
每个接口都带来了进行常用数值归约的新方法，比如对数值流求和的 sum ，找到最大元素的 max 。
此外还有在必要时再把它们转换回对象流的方法。
映射到数值流
将流转化为特化版本的常用方法为 mapToInt(),mapToDouble(),mapToLong().
这些方法和前面说的 map 方法的工作方式一样，只是它们返回的是一个特化流，而不是 Stream
@Test
public void test20() {
int sum = menu.stream() //返回一个Stream
.mapToInt(Dish::getCalories) //返回一个IntStream请注意，如果流是空的， sum 默认返回 0 。 IntStream 还支持其他的方便方法，如max 、 min 、 average 等。
转换回对象流 boxed()
同样，一旦有了数值流，你可能会想把它转换回非特化流。
IntStream intStream = menu.stream().mapToInt(Dish::getCalories);
Stream stream = intStream.boxed();
默认值 OptionalInt
要找到 IntStream 中的最大元素，可以调用 max 方法，它会返回一个 OptionalInt ：
OptionalInt optionalInt = menu.stream()
.mapToInt(Dish::getCalories)
.max();
现在，如果没有最大值的话，你就可以显式处理 OptionalInt 去定义一个默认值了：
@Test
public void test21() {
OptionalInt optionalInt = menu.stream()
.mapToInt(Dish::getCalories)
.max();
int max = optionalInt.orElse(0);
System.out.println(max);
}数值范围
和数字打交道时，有一个常用的东西就是数值范围。比如，假设你想要生成1和100之间的所有数字.
java8引入了两个可用于 IntStream 和LongStream的静态方法,range 和 rangeclosed.
这两个方法都是第一个参数接受起始值,第二个参数接受结束值,但range是不包含结束值的, rangeclosed包含结束值
@Test
public void test22() {
IntStream intStream = menu.stream()
.mapToInt(Dish::getCalories);
IntStream intStream1 = IntStream.range(1, 100)
.filter(n -> n % 2 == 0);
System.out.println(intStream1.count());
}6 构建流
本节将介绍如何从值序列、数组、文件来创建流，甚至由生成函数来创建无限流！
6.1 由值创建流
Stream.of()
你可以通过静态方法 Stream.of() 通过显示值创建一个流,他可以接受任意数量的参数.
@Test
public void test23() {
Stream stream = Stream.of("Java 8 ", "Lambdas ", "In ", "Action");
stream.map(String::toUpperCase).forEach(System.out::println);
}6.2 由数组创建流
Arrays.stream()
@Test
public void test25() {
int[] numbers = {2, 3, 5, 7, 11, 13};
IntStream intStream = Arrays.stream(numbers);
intArrays.stream() 有很多重载方法.
6.3 由文件创建流
java中用于处理文件等I/O操作的NIO API已经更新,以便利用Stream API.
java.nio.file.Files 中的很多静态方法都会返回一个流。例如，一个很有用的方法是
Files.lines ，它会返回一个由指定文件中的各行构成的字符串流.
统计一个文件中有多少各不相同的词:
@Test
public void test26() {
try {
Stream stream = Files.lines(Paths.get("data.txt"));
//Arrays.stream()把字符串数组转成流
long count = stream.flatMap(line -> Arrays.stream(line.split(" ")))
.distinct()
.count();
System.out.println(count);
} catch你可以使用Files.lines得到一个流,其中每个元素都是给定文件中的一行.
然后你可以对每一行进行split方法拆分单词,应该注意的是:你应该如何使用 flatMap()产生一个扁平的单词流.而不是给每一行生成一个单词流.
6.4 由函数生成流：创建无限流
Stream API 提供了两个静态方法来从函数生成流: Stream.iterate和Stream.generate.
这两个操作可以创建所谓的无限流：不像从固定集合创建的流那样有固定大小的流。由 iterate
和 generate 产生的流会用给定的函数按需创建值，因此可以无穷无尽地计算下去！一般来说，
应该使用 limit(n) 来对这种流加以限制，以避免打印无穷多个值.
迭代 iterate
@Test
public void test27() {
Stream.iterate(0,n->n+2)
.limit(10)
.forEach(System.out::println);
}iterate 方法接受一个初始值,还有一个作用于每次产生新值上的Lambda（ UnaryOperator 类型）,
这里，我们使用Lambda n -> n + 2 ，返回的是前一个元
素加上2。因此， iterate 方法生成了一个所有正偶数的流.
这种iterate基本上是顺序的,因为结果取决于前一次应用,请注意，此操作将生成一个无限流——这个流没有结尾，因为值是按需计算的，可以永远计算下去。我们说这个流是无界的。
生成 generate
与 iterate 方法类似， generate 方法也可让你按需生成一个无限流。但 generate 不是依次
对每个新生成的值应用函数的。它接受一个 Supplier 类型的Lambda提供新的值。我们先来
看一个简单的用法：
Stream.generate(Math::random)
.limit(5)
.forEach(System.out::println);
以上就是“java8流怎么使用”这篇文章的所有内容，感谢各位的阅读！相信大家阅读完这篇文章都有很大的收获，小编每天都会为大家更新不同的知识，如果还想学习更多的知识，请关注创新互联行业资讯频道。
网页标题：java8流怎么使用
转载来源：http://cdkjz.cn/article/jgogio.html
