java8之Stream API(从迭代器到Stream操作)

Wesley13
• 阅读 339

当你处理集合时,通常会迭代所有元素并对其中的每一个进行处理。例如,假设我们希望统计一个文件中的所有长单词:

package java8test;

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.Arrays;
import java.util.List;

public class T5 {
    public static void main(String[] args) {
        try {
            String contents = new String(Files.readAllBytes(
                    Paths.get("/home/fuhd/work/workspace/javaee/wwos.platform/pom.xml")),
                    StandardCharsets.UTF_8);
            List<String> words = Arrays.asList(contents.split("\n")); 
            //进行迭代
            int count = 0;
            for(String w: words){
                if(w.length() > 12) count++;
            }
            System.out.println(count);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

这里面有什么错误吗?其实没有——只是它很难被并行计算。这也是java8引入大量操作符的原因。在Java8中,实现相同功能的操作符如下所示:

package java8test;

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.Arrays;
import java.util.List;

public class T5 {
    public static void main(String[] args) {
        try {
            String contents = new String(Files.readAllBytes(
                    Paths.get("/home/fuhd/work/workspace/javaee/wwos.platform/pom.xml")),
                    StandardCharsets.UTF_8);
            List<String> words = Arrays.asList(contents.split("\n")); 
            //注意这一句
            long count = words.stream().filter(w -> w.length() > 12).count();
            System.out.println(count);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

stream方法会为单词列表生成一个Stream。filter方法会返回另一个只包含单词长度大于12的Stream。count方法会将Stream化简为一个结果。

一个Stream表面上看与一个集合很类似,允许你改变和获取数据。但是实际上它与集合是有很大区别的:

  • Stream自己不会存储元素。元素可能被存储在底层的集合中,或者根据需要产生出来。

  • Stream操作符不会改变源对象。相反,它们会返回一个持有结果的新Stream。

  • Stream操作符可能是延迟执行的。这意味着它们会等到需要结果的时候才执行。

许多人发现Stream表达式比循环的可读性更好。此外,它们还很容易进行并行执行。以下是一段如何并行统计长单词的代码:

package java8test;

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.Arrays;
import java.util.List;

public class T5 {
    public static void main(String[] args) {
        try {
            String contents = new String(Files.readAllBytes(
                    Paths.get("/home/fuhd/work/workspace/javaee/wwos.platform/pom.xml")),
                    StandardCharsets.UTF_8);
            List<String> words = Arrays.asList(contents.split("\n")); 
            //注意这一句,stream()改成了parallelStream()方法
            long count = words.parallelStream().filter(w -> w.length() > 12).count();
            System.out.println(count);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

只要将stream()方法改成parallelStream方法,就可以让Stream API并行执行过滤和统计操作。

Stream遵循“做什么,而不是怎么去做”的原则。在我们的示例中,描述了需要做什么:获得长单词并对它们的个数进行统计。我们没有指定按照什么顺序,或者在哪个线程中做,它们都是理所应当发生的。相反,循环在一开始就需要指定如何进行计算,因此就失去了优化的机会。

当你使用Stream时,你会通过三个阶段来建立一个操作流水线:

  • 创建一个Stream。

  • 在一个或多个步骤中,指定将初始Stream转换为另一个Stream的中间操作。

  • 使用一个终止操作来产生一个结果。该操作会强制它之前的延迟操作立即执行。在这之后,该Stream就不会再被使用

在我们的示例中,通过stream或者parallelStream方法来创建Stream,再通过filter方法对其进行转换,而count就是终止操作

注意:Stream操作不会按照元素的调用顺序执行。在我们的例子中,只有在count被调用的时候才会执行Stream操作。当count方法需要第一个元素时,filter方法会开始请求各个元素,直到找到一个长度大于12的元素。

点赞
收藏
评论区
推荐文章
blmius blmius
1年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
技术小男生 技术小男生
5个月前
linux环境jdk环境变量配置
1:编辑系统配置文件vi/etc/profile2:按字母键i进入编辑模式,在最底部添加内容:JAVAHOME/opt/jdk1.8.0152CLASSPATH.:$JAVAHOME/lib/dt.jar:$JAVAHOME/lib/tools.jarPATH$JAVAHOME/bin:$PATH3:生效配置
光头强的博客 光头强的博客
5个月前
Java面向对象试题
1、请创建一个Animal动物类,要求有方法eat()方法,方法输出一条语句“吃东西”。创建一个接口A,接口里有一个抽象方法fly()。创建一个Bird类继承Animal类并实现接口A里的方法输出一条有语句“鸟儿飞翔”,重写eat()方法输出一条语句“鸟儿吃虫”。在Test类中向上转型创建b对象,调用eat方法。然后向下转型调用eat()方
Karen110 Karen110
1年前
​一篇文章总结一下Python库中关于时间的常见操作
前言本次来总结一下关于Python时间的相关操作,有一个有趣的问题。如果你的业务用不到时间相关的操作,你的业务基本上会一直用不到。但是如果你的业务一旦用到了时间操作,你就会发现,淦,到处都是时间操作。。。所以思来想去,还是总结一下吧,本次会采用类型注解方式。time包importtime时间戳从1970年1月1日00:00:00标准时区诞生到现在
Easter79 Easter79
1年前
swap空间的增减方法
(1)增大swap空间去激活swap交换区:swapoff v /dev/vg00/lvswap扩展交换lv:lvextend L 10G /dev/vg00/lvswap重新生成swap交换区:mkswap /dev/vg00/lvswap激活新生成的交换区:swapon v /dev/vg00/lvswap
Wesley13 Wesley13
1年前
Java爬虫之JSoup使用教程
title:Java爬虫之JSoup使用教程date:201812248:00:000800update:201812248:00:000800author:mecover:https://imgblog.csdnimg.cn/20181224144920712(https://www.oschin
Stella981 Stella981
1年前
Python之time模块的时间戳、时间字符串格式化与转换
Python处理时间和时间戳的内置模块就有time,和datetime两个,本文先说time模块。关于时间戳的几个概念时间戳,根据1970年1月1日00:00:00开始按秒计算的偏移量。时间元组(struct_time),包含9个元素。 time.struct_time(tm_y
Wesley13 Wesley13
1年前
Java日期时间API系列36
  十二时辰,古代劳动人民把一昼夜划分成十二个时段,每一个时段叫一个时辰。二十四小时和十二时辰对照表:时辰时间24时制子时深夜11:00凌晨01:0023:0001:00丑时上午01:00上午03:0001:0003:00寅时上午03:00上午0
Stella981 Stella981
1年前
Docker 部署SpringBoot项目不香吗?
  公众号改版后文章乱序推荐,希望你可以点击上方“Java进阶架构师”,点击右上角,将我们设为★“星标”!这样才不会错过每日进阶架构文章呀。  !(http://dingyue.ws.126.net/2020/0920/b00fbfc7j00qgy5xy002kd200qo00hsg00it00cj.jpg)  2
Wesley13 Wesley13
1年前
PHP中的NOW()函数
是否有一个PHP函数以与MySQL函数NOW()相同的格式返回日期和时间?我知道如何使用date()做到这一点,但是我问是否有一个仅用于此的函数。例如,返回:2009120100:00:001楼使用此功能:functiongetDatetimeNow(){
Wesley13 Wesley13
1年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_