首页 / JAVA / java8新特性（二）StreamApi

java8新特性（二）StreamApi

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java8新特性（二）StreamApi，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含7229字，纯文字阅读大概需要11分钟。

内容图文

Stream的作用

stream是java8中处理集合的关键抽象信息，它可以指定希望对集合进行的操作，可以执行查找、过滤和映射数据等操作。

使用StreamApi对集合数据进行操作，就类似于使用使用sql对数据库操作。简而言之，StreamApi提供了高效且易于使用的数据处理方式。

java8新特性（二）StreamApi - 文章图片

什么是流？

流指的是用于操作数据源所生成的元素序列。

需要注意的是：

（1）stream不会自己存储元素；

（2）不会改变源对象，会返回一个新的stream

（3）stream是延迟执行的，意味着它们会等到需要结果的时候才会执行。

Stream操作的三个步骤：

（1）创建Stream

一个数据源（集合、数组）获取一个流；

（2）中间操作

一个中间操作链，对数据源的数据进行处理；

（3）终止操作

一个终止操作，执行中间操作链，产生结果。

案例

流的获取方式

   @Test
    public void test01(){
        // 可以通过Collection集合提供stream()或parallelStearam()
        List<String > list = new ArrayList<>();
        Stream<String> stream = list.stream();
        //通过Arrays的静态方法stream()获取数组流
        Employee[] employee = new Employee[10];
        Stream<Employee> stream1 = Arrays.stream(employee);
        //通过stream类中的静态方法of()
        Stream<String > stream2 = Stream.of("aa","bb","cc");

        //创建无限流
        Stream<Integer> stream3 = Stream.iterate(0,(x)->x+2);
        stream3.limit(10).forEach(System.out::println);
        System.out.println("-------------------------------------");
        Stream.generate(()->Math.random()).limit(5).forEach(System.out::println);
    }

中间操作与终止操作

    @Test
    public void test02(){

        List<Employee> employees = Arrays.asList(new Employee("张三",23),
                new Employee("李四",24),
                new Employee("王五",25),
                new Employee("王五",25));
        //中间操作：不会执行任何操作
        Stream<Employee> stream = employees.stream().filter((e)->{
            System.out.println("Stream Api中间操作");
            return e.getAge()>24;
        });
        //终止操作：一次执行全部操作，
        stream.forEach(System.out::println);
        System.out.println("---------------------------------------");
        employees.stream().filter((e)->e.getAge()>22).skip(1).forEach(System.out::println);
        System.out.println("-------------");
        //使用distinct方法要重写equals和hashcode方法
        employees.stream().filter((e)->e.getAge()>22).distinct().forEach(System.out::println);

    }

映射map方法和flatMap方法

    @Test
    public void test03(){
        List<String> strings = Arrays.asList("aaa","bbb","ccc");
        strings.stream().map((str)->str.toUpperCase()).forEach(System.out::println); //接收lambda操作，该函数将操作应用到每个元素上
        System.out.println("----------------------------------");
        employees.stream().map(Employee::getAge).forEach(System.out::println);
        System.out.println("----------------------------------");
        Stream<Stream<Character>> streamStream = strings.stream().map(StreamMain::filterChareacter);//map方法返回的是stream流
        streamStream.forEach((sm)->{
            sm.forEach(System.out::print); //需要嵌套for循环
        });
        System.out.println("----------------------------------");
        Stream<Character> characterStream = strings.stream().flatMap(StreamMain::filterChareacter);//flatMap返回的是元素
        characterStream.forEach(System.out::println);//不需要嵌套for循环

        //map和flatMap作用的对比类似于 add和addAll方法
        // Map是相当于把一个个流加入到当前流中，
        //FlatMap是相当于把一个个元素加入到当前流中。
        Collection<Object > aList = new ArrayList();
        Collection<Object > bList = new ArrayList();
        bList.add("13");
        bList.add("14");
        aList.add("12");
        aList.add(bList);
        System.out.println(aList);
    }

    //对字符串进行切分
    public static Stream<Character> filterChareacter(String str){
        List<Character> list = new ArrayList<>();
        for(Character ch :str.toCharArray()){
            list.add(ch);
        }
        return list.stream();
    }

sorted方法

   List<Employee> employees = Arrays.asList(new Employee("张三",23),
            new Employee("李四",24),
            new Employee("王五",25),
            new Employee("王五",25));    

@Test
    public void test04(){
        List<String > strings = Arrays.asList("aaa","ccc","bbb","ddd");
        strings.stream().sorted().forEach(System.out::println);
        //按年龄排序  如果年龄相同则按姓名排序
        employees.stream().sorted((e1,e2)->{
            if(e1.getAge()==(e2.getAge())){
                return e1.getUserName().compareTo(e2.getUserName());
            }else {
                return e1.getAge().compareTo(e2.getAge());
            }
        }).forEach(System.out::println);
    }

allmatch方法

@Test
    public void test05(){
       boolean flag = employees.stream().allMatch((e)->e.getAge().equals(25)); //检查是否匹配所有元素
        System.out.println(flag);

        boolean b2 = employees.stream().anyMatch((e)->e.getAge().equals(25));
        System.out.println(b2);

        boolean b3 = employees.stream().noneMatch((e)->e.getAge().equals(25));//检查所有元素是否都不匹配
        System.out.println(b3);

        Optional<Employee> first = employees.stream().sorted((e1, e2) ->
                -Integer.compare(e1.getAge(), e2.getAge())
        ).findFirst();
        System.out.println(first);

        Optional<Employee> any = employees.parallelStream().filter((e) -> e.getAge().equals(24)).findAny();
        System.out.println(any);;
    }

count方法

    @Test
    public void test06(){
        Optional<Integer> min = employees.stream().map(Employee::getAge).min(Integer::compare);
        System.out.println(min);

        Optional<Employee> max = employees.stream().max((e1, e2) -> Integer.compare(e1.getAge(), e2.getAge()));
        System.out.println(max);

        long count = employees.stream().count();
        System.out.println(count);
    }

reduce 规约

    //reduce 规约
    //可以将流中的元素反复结合起来，得到一个值
    @Test
    public void test07(){
        List<Integer> nums = Arrays.asList(1,2,3,4,5,6,7,8,9,10);
        Integer sum = nums.stream().reduce(0, (x, y) -> x + y);
        System.out.println(sum);

        Optional<Integer> sumInt = employees.stream().map(Employee::getAge)
                .reduce(Integer::sum);
        System.out.println(sumInt.get());
    }

collect方法

   //collect可以将流转化为其他形式
    @Test
    public void test08(){
        List<String> collect = employees.stream().map(Employee::getUserName)
                .collect(Collectors.toList());
        System.out.println(collect);
        System.out.println("----------------------");
        Set<String> collectSet = employees.stream()
                .map(Employee::getUserName)
                .collect(Collectors.toSet());
        collectSet.forEach(System.out::println);
        System.out.println("---------------------------");
        HashSet<String> collect1 = employees.stream().map(Employee::getUserName)
                .collect(Collectors.toCollection(HashSet::new));
        collect1.forEach(System.out::println);
    }

    @Test
    public void test09(){
        //总数
        Long collect = employees.stream()
                .collect(Collectors.counting());
        System.out.println(collect);
        //平均数
        Double avg = employees.stream()
                .collect(Collectors.averagingInt(Employee::getAge));
        System.out.println(avg);
        //总和
        Integer sum = employees.stream()
                .collect(Collectors.summingInt(Employee::getAge));
        System.out.println(sum);
    }

maxBy、minBy方法

    @Test
    public void test10(){
        Optional<Employee> collect = employees.stream()
                .collect(Collectors.maxBy((e1, e2) -> Integer.compare(e1.getAge(), e2.getAge())));
        System.out.println(collect.get());

        Optional<Integer> collect1 = employees.stream().map(Employee::getAge)
                .collect(Collectors.minBy(Integer::compare));
        System.out.println(collect1.get());
    }

分组

@Test
    public void teset01(){
        //按照某个属性分组
        Map<Integer, List<Employee>> collect = employees.stream()
                .collect(Collectors.groupingBy(Employee::getAge));
        System.out.println(collect);
        System.out.println("----------------------------------");
        //多级分组
        Map<Integer, Map<String, List<Employee>>> collect1 = employees.stream()
                .collect(Collectors.groupingBy(Employee::getAge, Collectors.groupingBy((e) -> {
                    if (((Employee) e).getSalary() > 24000) {
                        return "有钱人";
                    } else {
                        return "没钱人";
                    }
                })));
        System.out.println(collect1);
    }

分区

    //分区
    @Test
    public void test02(){
        Map<Boolean, List<Employee>> collect = employees.stream()
                .collect(Collectors.partitioningBy((e) -> e.getSalary() > 5000));
        System.out.println(collect);
    }

内容总结

以上是互联网集市为您收集整理的java8新特性（二）StreamApi全部内容，希望文章能够帮你解决java8新特性（二）StreamApi所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/624434.html

来源：【匿名】

【上一篇】JAVA线程池【下一篇】JAVA/JSP学习系列之五

更多 ►

【java8新特性（二）StreamApi】教程文章相关的互联网学习教程文章

java8 Lambda

Lambda表达式是Java SE 8中一个重要的新特性。lambda表达式允许你通过表达式来代替功能接口。 lambda表达式就和方法一样,它提供了一个正常的参数列表和一个使用这些参数的主体(body,可以是一个表达式或一个代码块)。Lambda表达式还增强了集合库。 Java SE 8添加了2个对集合数据进行批量操作的包: java.util.function 包以及java.util.stream 包。流(stream)就如同迭代器(iterator),但附加了许多额外的功能。在Lambda表达式中this是...

java7和java8新特性【代码】

以下来至网址：http://blog.csdn.net/samjustin1/article/details/52268004 Java7 新特性1.switch中可以使用字符串了String s = "test"; switch (s) { case "test" : System.out.println("test"); case "test1" : System.out.println("test1"); break ; default : System.out.println("break"); break ; } 2.运用List<String> tempList = new ArrayList<>();即泛型实例化类型自动推断3.语法上支持集...

Java8增加功能--Effectively final 功能

java8新增了很多功能，可以大大简化代码，这个系列将会一一辅助代码加以介绍。局部内部类和匿名内部类访问的局部变量必须由final修饰，java8开始，可以不加final修饰符，由系统默认添加。java将这个功能称为：Effectively final 功能。下面是完整掩饰代码（至少使用jdk1.8版本）：public class EffectivelyFinalDemo {public static void main(String[] args) {//局部内部类和匿名内部类访问的局部变量必须由fina...

Java8大排序算法【代码】【图】

一.冒泡排序　基本思想:通过对待排序序列此前向后,依次比较相邻元素的值,若发现逆序则进行交换,使得较大的值从前面移动到后面,　　　　类似于水下的气泡一样(是所有排序算法中效率最低的) publicstaticvoid BobbleSort(int[] arr){/*冒泡排序,时间复杂度为O(n^2)*/if (arr == null || arr.length == 0){return;}int temp = 0; // 临时变量,用...

java8实现的处理时间工具类（收藏）【代码】

1. 前期准备：① JDK：1.8② 编辑器：Eclipse③ Guava（创建集合的时候回用到，可以还原成JDK1.5的创建方式:new）2. 全部代码展示：package com.drew.util;import java.time.DayOfWeek; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.LocalTime; import java.time.MonthDay; import java.time.Period; import java.time.format.DateTimeFormatter; import java.time.format.FormatStyle; import ...

Java8新特性 - Optional容器类【代码】

Optional 类(java.util.Optional) 是一个容器类，代表一个值存在或不存在，原来用null 表示一个值不存在，现在Optional 可以更好的表达这个概念。并且可以避免空指针异常。Optional.of(T t) : 创建一个Optional 实例Optional.empty() : 创建一个空的Optional 实例Optional.ofNullable(T t):若t 不为null,创建Optional 实例,否则创建空实例isPresent() : 判断是否包含值orElse(T t) : 如果调用对象包含值，返回该值，否则返回torEls...

java8 去重属性增强【代码】

通过Stream.filter不同属性来过滤重复/*** 通过对象属性去重** @param keyExtractor* @param <T>* @return*/public static <T> Predicate<T> distinctByKey(Function<? super T, Object> keyExtractor) {Set<Object> seen = ConcurrentHashMap.newKeySet();return t -> seen.add(keyExtractor.apply(t));}根据属性去重，并且进行信息整合/*** 通过对象属性去重，并对相同Key的对象执行操作，适合两个list相同属性并集** @param key...

java8--排序sort【代码】

利用java8，可以很方便的对List内的元素进行正序、倒叙操作~对数字排序//对数字进行排序 List<Integer> nums = Arrays.asList(3,1,5,2,9,8,4,10,6,7); nums.sort(Comparator.reverseOrder()); //reverseOrder倒序 System.err.println("倒序:"+nums);//倒序:[10, 9, 8, 7, 6, 5, 4, 3, 2, 1] nums.sort(Comparator.naturalOrder());//naturalOrder自然排序即：正序 System.err.println("正序:"+nums);//正序:[1, 2, 3, 4, 5, 6, 7, ...

使用java8轻松处理日期【图】

可能Oracle也意识到java处理日期的能力的不足，所以在Java8新增了 LocalDate和LocalTime接口。众所周知java.util.Date的月份是从0开始算起~0代表一月，1代表二月~呵呵。确实刚开始接触的时候笔者也用得很纠结~~很烦躁~不过Java8的LocalDate已经改进了这一点~~因为LocalDate的月份是利用枚举（enum）储存的。妈妈再也不用担心我用错啦~~~相信有读者已经发现~java.util.Date通用的可以储存年月日时分秒甚至毫秒~~而java8分成了两部分...

品HashMap（java8）【代码】【图】

前言作为java开发人员，HashMap可谓是业务中的一把利器，9龙再次捡起这老生常谈的知识点，深入源码，细细品味。首先，我们抛出几个关于HashMap的问题，带着问题去学习，就像捉迷藏一样有意思。1、为什么要使用HashMap？HashMap有什么特性？2、HashMap的主要参数有哪些？都有什么作用？3、HashMap是基于什么数据结构实现的？4、构造HashMap时传入的初始容量是如何处理的？为什么要这样做？5、HashMap在什么时候扩容？扩容的时候都做...

java8 日期api使用【代码】

java8以前对日期的处理不是很方便，想要对日期进行加减，比较两个日期的间隔处理非常繁琐，java8对日期重新实现了一套api，位于java.time包下。 LocalDate 只显示日期 LocalTime 只显示时间 LocalDateTime 既包括日期又包括时间 Instant 时间戳 ZoneId 时区1 用法： LocalDate ,LocalTime,LocalDateTime 这几个类的构造方法都是private,但他们都提供了静态的方法来实例化对象。 1.1 of(int year, Month mon...

Java8 Stream流常用方法及例子【代码】

交易员和交易的实体类的定义如下：Trader.classpublic class Trader {private String name;private String city;public Trader(String n, String c) {this.name = n;this.city = c;}public String getName() {return this.name;}public String getCity() {return this.city;}public void setCity(String newCity) {this.city = newCity;}public String toString() {return "Trader:" + this.name + " in " + this.city;} } Transac...

Java8 Nashorn实现Java调用javascript代码【代码】

最近项目需要，利用java执行动态语言，首先想到的是支持js。1.从打印Hello World开始Java8 引入Nashorn实现javascript调用，比如使用java运行一段js实现“Hello World”打印：package com.iflytek.research.jsdemo;import javax.script.ScriptEngine; import javax.script.ScriptEngineManager; import javax.script.ScriptException;public class NashornTest {public static void main(String[] args) {// 加载nashorn执行引擎Sc...

Java8新特性

1、新的日期和时间APIhttps://waltyou.github.io/Java8-In-Action-4-EffectiveJavaPrograming/#top原文：https://www.cnblogs.com/yixiu868/p/11609171.html

Java8 实战读书笔记（1~3章）【代码】

Java8 实战读书笔记第一章为什么要关心Java 8要点流处理用行为参数化把代码传递给方法并行与共享可变数据外部迭代（需要手动调用for-each去一个个迭代）内部迭代（迭代在库内进行，不需要手动调用for-each）Java 8 Stream API 解决了集合处理时的套路和晦涩,以及难以利用多核。使用默认方法，在实现类没有实现方法是提供方法内容第二章通过行为参数化传递代码概述这章主要介绍由于不断变更需求带来工作量，以及使用行为参数化的...

首页 / JAVA / java8新特性（二）StreamApi

java8新特性（二）StreamApi

内容导读

内容图文

Stream的作用

什么是流？

Stream操作的三个步骤：

案例

流的获取方式

中间操作与终止操作

映射map方法和flatMap方法

sorted方法

allmatch方法

count方法

reduce 规约

collect方法

maxBy、minBy方法

分组

分区

内容总结

内容备注

内容手机端

【java8新特性（二）StreamApi】教程文章相关的互联网学习教程文章

JAVA8 - 相关标签

TR - 相关标签

JAVA - 技术教程分类

JAVA - 最新教程

JAVA - 最热教程