Java | Stream

简介

Stream流 是 JDK1.8 加入的新特性，Stream流跟I/O流不同，Stream流用于操作数据源（集合、数组等）所生成的元素序列。

Stream 有几个特点：

  • 它不会存储元素
  • 延迟执行，Stream 会等到需要结果时才会执行
  • 不会改变数据源（使用map方法可以通过对象引用还改变源数据）
  • 对 Stream 的操作是以 lamnda 表达式为参数的
  • 可以是无限的，用 Stream 可以轻松表示全体自然数，这是集合类不可能做到的。
  • stream的聚合、消费或收集操作只能进行一次，再次操作会报错，Stream 就如同一个迭代器（Iterator），单向，不可往复，数据只能遍历一次，遍历过一次后即用尽了

使用 Stream 有三个步骤:

  1. 创建一个Stream流
  2. 中间操作
  3. 终止操作
创建
        // 1. 通过Collections系列集合提供的stream() 或 parallelStream()
        List<String> list = new ArrayList<>();
        Stream<String> stream01 = list.stream();
        
        // 2. 通过Arrays中的静态方法stream()获取数组流
        String[] strList = new String[10];
        Stream<String> stream02 = Arrays.stream(strList);
        
        // 3. 通过Stream类中的静态方法
        Stream<String> stream03 = Stream.of(strList);
        
        // 4. 迭代
        Stream<Integer> stream04 = Stream.iterate(0, (x) -> (x + 1));
        stream04.limit(10).forEach(System.out::println);
        
        // 5. 生成
        Stream<Double> stream05 = Stream.generate(() -> Math.random());
        stream05.limit(10).forEach(System.out::println);
中间操作

数据源：

        List<Human> list = new ArrayList<>();
        list.add(new Human("小王", 31, "男"));
        list.add(new Human("小黑", 24, "女"));
        list.add(new Human("小张", 10, "男"));
        list.add(new Human("胖虎", 15, "男"));
        list.add(new Human("小王", 31, "男"));
        list.add(new Human("胖虎", 15, "男"));

获取Stream

Stream<Human> stream = list.stream();

过滤，获取大于二十岁的：

stream.filter(item -> item.getAge() > 20).forEach(System.out::println);

切片，利用skip跟limit方法 配合使用实现切片

// 切片，获取下标 [2,4) 的元素
stream.skip(2).limit(3).forEach(System.out::println);

映射，将函数作用在流的每个元素上

// 所有人年龄加 1
stream.map(item ->{item.setAge(item.getAge() + 1); return item;}).forEach(System.out::println);

扁平化，例如将字符数组的字符转换为字母，并将重复字母去掉

List<String> words = Arrays.asList("Hello", "Wrold");
        words.stream()
            .map(word -> word.split(""))
            .flatMap((Arrays::stream))  // 扁平化，把map(Arrays::stream)生成的单个流合并成一个流
            .distinct()
            .forEach(System.out::println);

去重

// 利用hashcode 跟 equals 作为重复判断依据
stream04.distinct().forEach(System.out::println);

还可以将多个中间操作配合使用，比如加入有业务需要 无重复的列出所有已成年男性，我们就可以这样写

        stream
            .filter(item -> item.getAge() > 18 && "男".equals(item.getSex()))  // 过滤掉未成年及女生
            .distinct()  // 去重，是利用HashCode与equals方法去重
            .forEach(System.out::println);  // 终止操作

在上面的示例中 .forEach() 就是终止操作

将Strea生成一个新的集合

// 转换为ArrayList
Stream<Integer> stream01 = Stream.iterate(0, x -> (x + 1));
stream01.limit(10).collect(Collectors.toList())

// 转换为HashSet
Stream<Integer> stream02 = Stream.iterate(0, x -> (x + 1));
stream02.limit(10).collect(Collectors.toSet())

用 Stream 表示全体自然数（其实就是上面迭代的那个例子）

// 全体自然数
Stream<Integer> stream = Stream.iterate(0, x -> (x + 1));
// 取前十个
stream.limit(10).forEach(System.out::println);

利用函数式接口 Supplier 实现

public class Natural implements Supplier<Integer> {
    
    private Integer number = 0;
    // 获取自然数
    @Override
    public Integer get() {
        
        return this.number++;
    }
    
}

    @Test
    public void test03() {
        
        Stream<Integer> stream = Stream.generate(new Natural());
        stream.limit(10).forEach(System.out::println);
    }

package stream;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import java.util.stream.Stream;

import org.junit.Test;



public class StreamDemo {
    
    /*
     * 获取Stream的方式
     */
    
    @Test
    public void test01() {      
        // 1. 通过Collections系列集合提供的stream() 或 parallelStream()
        List<String> list = new ArrayList<>();
        Stream<String> stream01 = list.stream();
        
        
        // 2. 通过Arrays中的静态方法stream()获取数组流
        String[] strList = new String[10];
        Stream<String> stream02 = Arrays.stream(strList);
        
        // 3. 通过Stream类中的静态方法
        Stream<String> stream03 = Stream.of(strList);
        
        // 4. 迭代
        Stream<Integer> stream04 = Stream.iterate(0, (x) -> (x + 2));
        stream04.limit(10).forEach(System.out::println);
        
        // 5. 生成
        Stream<Double> stream05 = Stream.generate(() -> Math.random());
        stream05.limit(10).forEach(System.out::println);
    }
    
    /*
     * 中间API
     */
    @Test
    public void test02() {
        List<Human> list = new ArrayList<>();
        list.add(new Human("小王", 31, "男"));
        list.add(new Human("小黑", 24, "女"));
        list.add(new Human("小张", 10, "男"));
        list.add(new Human("胖虎", 15, "男"));
        list.add(new Human("小王", 31, "男"));
        list.add(new Human("胖虎", 15, "男"));
        
        // 获取流
        Stream<Human> stream = list.stream();
        
//      list.get(1).setAge(45);
        
        /*
         *  中间操作
         */
        
        // 过滤
        Stream<Human> stream01 = list.stream();
        System.out.println("============== 过滤 ================");
        stream01.filter(item -> item.getAge() > 20).forEach(System.out::println);
        
        // 切片，取下标 [2,4) 的元素
        Stream<Human> stream02 = list.stream();
        System.out.println("=============== 切片 ===============");
        stream02.skip(2).limit(3).forEach(System.out::println);
        
        
        // 去重
        Stream<Human> stream04 = list.stream();
        System.out.println("=============== 去重 ===============");
        stream04.distinct().forEach(System.out::println);
        
        // 映射，将函数作用于每个元素
        Stream<Human> stream05 = list.stream();
        System.out.println("=============== 映射 ===============");
        stream05.map(item ->{item.setAge(item.getAge() + 1); return item;}).forEach(System.out::println);
        
        // 中间操作返回的还是Stream，所以可以将多个中间操作组合使用
        Stream<Human> stream06 = list.stream();
        System.out.println("=============== 配合使用 ===============");
        stream06
            .filter(item -> item.getAge() > 18 && "男".equals(item.getSex()))  // 过滤掉未成年及女生
            .distinct()  // 去重，是利用HashCode与equals方法去重
            .forEach(System.out::println);  // 终止操作
        
        
        System.out.println("=============== 查看数据是否被改变 ===============");
        for (Human human : list) {
            System.out.println(human);
        }
    }
    
    /**
     * 自然数一
     */
    @Test
    public void test03() {
        
        Stream<Integer> stream = Stream.generate(new Natural());
        stream.limit(10).forEach(System.out::println);
    }
    /**
     * 自然数二
     */
    @Test
    public void test04() {
        Stream<Integer> stream = Stream.iterate(0, x -> (x + 1));
        stream.limit(10).forEach(System.out::println);
    }
    
    
    @Test
    public void test05() {
        
        // 转换为ArrayList
        Stream<Integer> stream01 = Stream.iterate(0, x -> (x + 1));
        System.out.println(stream01.limit(10).collect(Collectors.toList()).getClass());
        
        // 转换为HashSet
        Stream<Integer> stream02 = Stream.iterate(0, x -> (x + 1));
        System.out.println(stream02.limit(10).collect(Collectors.toSet()).getClass());
    }
    
    /**
     * 分组
     */
    @Test
    public void test06() {
        List<Human> list = new ArrayList<>();
        list.add(new Human("小王", 31, "男"));
        list.add(new Human("小黑", 24, "女"));
        list.add(new Human("小张", 10, "男"));
        list.add(new Human("胖虎", 15, "女"));
        list.add(new Human("小王", 31, "男"));
        list.add(new Human("胖虎", 15, "女"));
        
        Stream<Human> stream = list.stream();
        
        Map<String, List<Human>> map = stream.collect(Collectors.groupingBy(Human::getSex));
        System.out.println(map.size() + ": " + map.keySet());
        System.out.println(map.get("男"));
        System.out.println(map.get("女"));
    }
}
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 214,233评论 6赞 495
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 91,357评论 3赞 389
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 159,831评论 0赞 349
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 57,313评论 1赞 288
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 66,417评论 6赞 386
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 50,470评论 1赞 292
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,482评论 3赞 412
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 38,265评论 0赞 269
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 44,708评论 1赞 307
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,997评论 2赞 328
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,176评论 1赞 342
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 34,827评论 4赞 337
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,503评论 3赞 322
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,150评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,391评论 1赞 267
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 47,034评论 2赞 365
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 44,063评论 2赞 352

推荐阅读更多精彩内容

  • Spring Cloud
    Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智...
    卡卡罗2017阅读 134,644评论 18赞 139
  • Java Stream
    在处理集合时，我们通常会遍历它的元素，并在每个元素上执行某项操作。例如，假设要对某个列表中所有长单词进行计数： 使...
    杰哥长得帅阅读 195评论 1赞 0
  • 迷茫
    我的未来在哪啊？
    70ea495b28aa阅读 314评论 0赞 1
  • 炎夏吃货狂想
    云南最热的时候，不在暑期，而在五月。 今天最高温达28℃，这在素有“春城”之称的昆明，已经算是逼近上限。搞得气象局...
    甜乌阅读 261评论 0赞 1
  • 那些藏于岁月的美好，存在于有张国荣的世界
    所有赞美哥哥的话语，词藻再华美，都不过分，何况赞美哥哥的字词一向都是很平淡的。 有人说，与哥哥的才华相比，他的容貌...
    阳青睿阅读 574评论 0赞 1