JDK8新特性之Stream流

是什么是Stream流

java.util.stream.Stream

Stream流和传统的IO流,它们都叫流,却是两个完全不一样的概念和东西。

流可以简单的说是处理数据集合的东西,可以申明式流式API来处理集合,而不是写一个逻辑实现。

流分类

流分为顺序流及并行流,顺序流即每个指令按顺序执行,并行流即集合里面的操作并行执行。

List<Integer> numbers = Arrays.asList(1, 2, 3);

// 顺序流
numbers.stream().forEach(n -> System.out.print(n));

//并行流
numbers.parallelStream().forEach(n -> System.out.print(n));

以上例子,顺序流总是输出 123,而并行流则每次结果都不一定,并行流使用了ForkJoinPool分而治之,所以明白了ForkJoinPool原理的同学就知道并行流的真面目了。

创建流

1、调用集合的stream()方法或者parallelStream()方法。

2、Stream.of()方法,有针对int,long的专用流IntStream,LongStream。

使用流

以下举了流的一些常用的用法。

public class StreamTest {

    public static void main(String[] args) {
        System.out.println("过滤-找出年纪大于18岁的人");
        List<User> list = initList();
        list.stream().filter((User user) -> user.getAge() > 18).collect(Collectors.toList())
                .forEach(System.out::println);
        System.out.println();

        System.out.println("最大值-找出最大年纪的人");
        list = initList();
        Optional<User> max = list.stream().max((u1, u2) -> u1.getAge() - u2.getAge());
        System.out.println(max.get());
        System.out.println();

        System.out.println("映射-规纳-求所有人的年纪总和");
        list = initList();
        Optional<Integer> reduce = list.stream().map(User::getAge).reduce(Integer::sum);
        System.out.println(reduce.get());
        System.out.println();

        System.out.println("分组-按年纪分组");
        list = initList();
        Map<Integer, List<User>> userMap = list.stream()
                .collect(Collectors.groupingBy(User::getAge));
        MapUtils.verbosePrint(System.out, null, userMap);
        System.out.println();

        System.out.println("创建-去重-统计");
        Stream<User> userStream = Stream
                .of(new User("u1", 1), new User("u2", 21), new User("u2", 21));
        System.out.println(userStream.distinct().count());
        System.out.println();

    }

    public static List<User> initList() {
        List<User> list = new ArrayList<>();
        list.add(new User("oaby", 23));
        list.add(new User("tom", 11));
        list.add(new User("john", 16));
        list.add(new User("jennis", 26));
        list.add(new User("tin", 26));
        list.add(new User("army", 26));
        list.add(new User("mack", 19));
        list.add(new User("jobs", 65));
        list.add(new User("jordan", 23));
        return list;
    }

}

输出结果:

过滤-找出年纪大于18岁的人
User [username=oaby, age=23]
User [username=jennis, age=26]
User [username=tin, age=26]
User [username=army, age=26]
User [username=mack, age=19]
User [username=jobs, age=65]
User [username=jordan, age=23]

最大值-找出最大年纪的人
User [username=jobs, age=65]

映射-规纳-求所有人的年纪总和
235

分组-按年纪分组
{
    16 = [User [username=john, age=16]]
    65 = [User [username=jobs, age=65]]
    19 = [User [username=mack, age=19]]
    23 = [User [username=oaby, age=23], User [username=jordan, age=23]]
    26 = [User [username=jennis, age=26], User [username=tin, age=26], User [username=army, age=26]]
    11 = [User [username=tom, age=11]]
}

创建-去重-统计
2

可以看出流操作数据集合很强大吧,但需要注意的是流只能执行一次,再次使用需要重要打开。

更多的玩法可以自己去研究吧。

本文分享自微信公众号 - Java技术栈(javastack)

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2017-10-02

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Golang语言社区

连接池

连接池是创建和管理一个连接的缓冲池的技术,这些连接准备好被任何需要它们的线程使用。 好处 编辑 这种连接“汇集”起来的技术基于这样的一个事实:对于大多数应用程序...

40860
来自专栏Java帮帮-微信公众号-技术文章全总结

【Java提高二】三大特性-继承

【Java提高】三大特性-继承 在《Think in java》中有这样一句话:复用代码是Java众多引人注目的功能之一。但要想成为极具革命性的语言,仅仅能够...

36890
来自专栏Java帮帮-微信公众号-技术文章全总结

【学习经验】Java中常用英文

【学习经验】Java中常用英文 第一章: public['pʌblik] 公共的,公用的 static['stætik] 静的;静态的...

388100
来自专栏Java帮帮-微信公众号-技术文章全总结

【Java提高三】三大特性-多态

【Java提高】三大特性-多态 面向对象编程有三大特性:封装、继承、多态。 封装隐藏了类的内部实现机制,可以在不影响使用的情况下改变类的内部结构...

40590
来自专栏Java帮帮-微信公众号-技术文章全总结

【编程题】Java编程题五(10道)

【编程题】Java编程题六(10道) 【程序41】 题目:海滩上有一堆桃子,五只猴子来分。第一只猴子把这堆桃子凭据分为五份,多了一个,这只猴子把多的一个扔入海...

497120
来自专栏Java帮帮-微信公众号-技术文章全总结

【Java提高五】使用序列化实现对象的拷贝

【Java提高五】使用序列化实现对象拷贝 我们知道在Java中存在这个接口Cloneable,实现该接口的类都会具备被拷贝的能力,同时拷贝是在内存中进行,在性能...

37880
来自专栏Java帮帮-微信公众号-技术文章全总结

【选择题】Java基础测试九(16道)

【选择题】Java基础测试九(16道) 117.下列说法正确的有() A. class中的constructor不可省略 B. constructo...

39570
来自专栏杨建荣的学习笔记

对于随机数的一些分析

多年前我朋友圈的一个朋友公司年会抽奖出现了下面的这样一幕:CTO现场review代码。本来带着一丝娱乐精神,结果被无限放大了。所以年会中大家都会很自然想revi...

39080
来自专栏Java帮帮-微信公众号-技术文章全总结

03.单例模式

03.单例模式 单例模式 单例模式(Singleton Pattern)是 Java 中最简单的设计模式之一。这种类型的设计模式属于创建型模式,它提供了一种创建...

31880
来自专栏Java帮帮-微信公众号-技术文章全总结

【Java提高四】接口与抽象类

【Java提高四】接口与抽象类 接口和内部类为我们提供了一种将接口与实现分离的更加结构化的方法。 抽象类与接口是java语言中对抽象概念进行定义的...

38360

扫码关注云+社区

领取腾讯云代金券

年度创作总结 领取年终奖励