Java8特性③Stream的使用

时间  2019-11-16
标签 java8 java 特性 stream 使用 栏目 Java 繁體版
原文   原文链接

筛选和切片

  • filter 方法java

  • distinct 方法数组

  • limit 方法dom

  • skip 方法ide

谓词筛选

Stream 接口支持 filter 方法，该操做会接受一个谓词（一个返回 boolean的函数）做为参数，并返回一个包括全部符合谓词的元素的流。函数

List<Dish> dishes = Dish.menu.stream()
      .filter(Dish::isVegetarian)
      .collect(Collectors.toList());

筛选重复的元素

Stream 接口支持 distinct 的方法， 它会返回一个元素各异（根据流所生成元素的 hashCode和equals方法实现）的流。例如，如下代码会筛选出列表中全部的偶数，并确保没有 重复。this

List<Integer> numbers = Arrays.asList(1,2,1,3,3,2,4);
numbers.stream().filter(i -> i % 2 == 0)
      .distinct() //去重元素2
      .forEach(System.out::println);

限制元素数量

Stream 支持limit(n)方法，该方法会返回一个不超过给定长度的流。所需的长度做为参数传递 给limit。若是流是有序的，则最多会返回前n个元素。spa

List<Dish> dishLimits = Dish.menu.stream()
        .filter(d -> d.getCalories() > 300)
        .limit(3) //只返回符合要求的前3个元素
        .collect(Collectors.toList());

跳过指定数量的元素

Stream 支持 skip(n) 方法，返回一个扔掉了前n个元素的流。若是流中元素不足n个，则返回一 个空流。limit(n) 和 skip(n) 是互补的。code

List<Dish> dishSkip = Dish.menu.stream()
        .filter(d -> d.getCalories() > 300)
        .skip(2) //去掉符合要求的集合中的前2个元素后返回
        .collect(Collectors.toList());
dishSkip.forEach(System.out::println);

映射

map 操做

Stream 支持 map 方法，它会接受一个函数做为参数。这个函数会被应用到每一个元素上，并将其映 射成一个新的元素对象

List<Integer> dishNames = Dish.menu.stream()
      .map(Dish::getName)
      .map(String::length)
      .collect(Collectors.toList());
 
List<String> words = Arrays.asList("Hello", "World");
List<Integer> wordLens = words.stream()
      .map(String::length) //转为字符串长度的集合
      .collect(Collectors.toList());

flatMap 操做

flatmap 方法让你把一个流中的每一个值都换成另外一个流，而后把全部的流链接起来成为一个流。blog

//使用flatMap找出单词列表中各不相同的字符
List<String> words = Arrays.asList("Hello", "World");
List<String> wordMap = words.stream()
      .map(word -> word.split(""))
      .flatMap(Arrays::stream)
      .distinct()
      .collect(Collectors.toList());

给定两个数字列表，如何返回全部的数对呢？例如，给定列表[1, 2, 3]和列表[3, 4]，应该返回[(1, 3), (1, 4), (2, 3), (2, 4), (3, 3), (3, 4)]。

List<Integer> num1 = Arrays.asList(1, 2, 3);
List<Integer> num2 = Arrays.asList(4, 5);
List<int[]> pairs = num1.stream()
        .flatMap(i -> num2.stream().map(j -> new int[]{i, j}))
        .collect(Collectors.toList());
pairs.stream().forEach( i -> {
    Arrays.stream(i).forEach(System.out::println);

查找和匹配

anyMatch

流中是否有一个元素能匹配给定的谓词。

if (Dish.menu.stream().anyMatch(Dish::isVegetarian)) {
     System.out.println("Vegetarion");
 }

allMatch

流中是否有全部元素能匹配给定的谓词。

if (Dish.menu.stream().allMatch(d -> d.getCalories() < 1000)) {

     System.out.println("都有利于健康");
 }

nonMatch

流中是否有没有任何元素能匹配给定的谓词。

if (Dish.menu.stream().noneMatch(d -> d.getCalories() >= 1000)) {

     System.out.println("都有利于健康");
 }

findAny

findAny 方法将返回当前流中的任意一个元素。

Optional<Dish> dish = Dish.menu.stream().filter(Dish::isVegetarian)
         .findAny();
 dish.ifPresent(d -> System.out.println(d.toString()));

findFirst

findAny 方法将返回当前流中的第一个元素。

List<Integer> num1 = Arrays.asList(1, 2, 3, 4, 5);
 num1.stream().map(x -> x * x)
         .filter(x -> x % 3 == 0) //平方能被3整除的数
         .findFirst().ifPresent(x -> System.out.println(x));
      }

Optional

Optional<T>类（java.util.Optional）是一个容器类，表明一个值存在或不存在。Optional里面y有几种显式地检查值是否存在或处理值不存在的情形的方法：

  • isPresent()将在Optional包含值的时候返回true, 不然返回false。

  • ifPresent(Consumer<T> block))会在值存在的时候执行给定的代码块。

  • T get()会在值存在时返回值，不然抛出一个NoSuchElement异常。

  • T orElse(T other)会在值存在时返回值，不然返回一个默认值。

归约（reduce）

把一个流中的元素组合起来，使用 reduce 操做来表达更复杂的查 询，好比“计算菜单中的总卡路里”或“菜单中卡路里最高的菜是哪个”。此类查询须要将流中全部元素反复结合起来，获得一个值，好比一个Integer。这样的查询能够被归类为归约操做 （将流归约成一个值）。

reduce操做是如何做用于一个流的：Lambda反复结合每一个元素，直到流被归约成一个值。reduce方法接受两个参数：一个初始值，这里是0；一个 BinaryOperator<T> 来将两个元素结合起来产生一个新值， 这里咱们用的是 lambda (a, b) -> a + b。

元素求和

List<Integer> numbers = Arrays.asList(3,4,5,1,2);
int sum1 = numbers.stream().reduce(0,(a, b) -> a + b);
System.out.println(sum1);

int sum2 = numbers.stream().reduce(0,Integer::sum);
System.out.println(sum2);

最大值

int max = numbers.stream().reduce(0,Integer::max);
System.out.println(max);

最小值

//reduce不接受初始值，返回一个Optional对象（考虑流中没有任何元素的状况）
Optional<Integer> min = numbers.stream().reduce(Integer::min);
min.ifPresent(System.out::println);

数值流

原始类型流特化

Java 8引入了三个原始类型特化流接口来解决这个问题： IntStream 、 DoubleStream 和 LongStream，分别将流中的元素特化为int、long和double，从而避免了暗含的装箱成本。每 个接口都带来了进行经常使用数值归约的新方法，好比对数值流求和的sum，找到最大元素的max。 此外还有在必要时再把它们转换回对象流的方法。这些特化的缘由并不在于流的复杂性，而是装箱形成的复杂性——即相似int和Integer之间的效率差别。

  • 映射到数值流：将流转换为特化版本的经常使用方法是mapToInt、mapToDouble和mapToLong。这些方法和前 面说的map方法的工做方式同样，只是它们返回的是一个特化流，而不是Stream<T>。

int colories = Dish.menu.stream()
        .mapToInt(Dish::getCalories) //返回IntStream
        .sum();

  • 转换回对象流

经过 box 方法能够将数值流转化为 Stream 非特化流。

IntStream intStream = menu.stream().mapToInt(Dish::getCalories); //将Strean转化为数值流
Stream<Integer> stream = intStream.boxed(); //将数值流转化为Stream

  • 默认值 OptionalInt

Optional 能够用 Integer、String等参考类型来参数化。对于三种原始流特化，也分别有一个Optional原始类 型特化版本：OptionalInt、OptionalDouble和OptionalLong。

Dish.menu.stream()
        .mapToInt(Dish::getCalories) //返回IntStream
        .max().ifPresent(System.out::println);

数值范围

IntStream.rangeClosed(1, 100)
        .filter(x -> x % 10 == 0)
        .forEach(System.out::println);

Java 8引入了两个能够用于IntStream和LongStream的静态方法，帮助生成这种范围： range和rangeClosed。这两个方法都是第一个参数接受起始值，第二个参数接受结束值。但 range是不包含结束值的，而rangeClosed则包含结束值。

数值流应用：勾股数

生成 (5, 12, 13)、(6, 8, 10)和(7, 24, 25) 这样有效的勾股数数组集合。

Stream<int[]> pythagoreanTriples = IntStream.rangeClosed(1, 100).boxed()
        .flatMap(a -> IntStream.rangeClosed(a,100)
                                .filter(b -> Math.sqrt(a * a + b * b) % 1 == 0).boxed()
                                .map(b -> new int[]{a,b,(int)Math.sqrt(a * a + b * b)})
        );
pythagoreanTriples.forEach(t -> System.out.println(t[0] + ";" + t[1] +";" + t[2]));

构建流

值建立流

Stream<String> streams = Stream.of("Java", "Python");
streams.map(String::toUpperCase).forEach(System.out::println);

Stream.concat(Stream.of("Java", "Python"), Stream.of("C++", "Ruby")).forEach(System.out::println);

数组建立流

int[] numbers = {1, 2, 3, 4, 5, 6, 7, 8, 9};
int sum = Arrays.stream(numbers).sum();

文件生成流

String ret = Files.lines(Paths.get("/Users/liuguoquan/Java/java8/src/com/company/data.txt"), Charset.defaultCharset())
        .reduce("", (a, b) -> a + " " + b);

函数生成流：建立无限流

//迭代
Stream.iterate(0, n -> n + 2)
        .limit(10)
        .forEach(System.out::println);

//生成
Stream.generate(Math::random)
        .limit(5)
        .forEach(System.out::println);

    }

示例实战

假设你是执行交易的交易员。你的经理让你为八个查询找到答案。你能作到吗？

  • (1) 找出2016年发生的全部交易，并按交易额排序（从低到高）。

  • (2) 交易员都在哪些不一样的城市工做过？

  • (3) 查找全部来自于北京的交易员，并按姓名排序。

  • (4) 返回全部交易员的姓名字符串，按字母顺序排序。

  • (5) 有没有交易员是在深圳工做的？

  • (6) 打印生活在北京的交易员的全部交易额。

  • (7) 全部交易中，最高的交易额是多少？

  • (8) 找到交易额最小的交易。

交易员类

/**
 * 交易人
 * Created by liuguoquan on 2017/4/28.
 */
public class Trader {

    private String name;
    private String city;

    public Trader(String name, String city) {
        this.name = name;
        this.city = city;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getCity() {
        return city;
    }

    public void setCity(String city) {
        this.city = city;
    }

    @Override
    public String toString() {
        return "Trader{" +
                "name='" + name + '\'' +
                ", city='" + city + '\'' +
                '}';
    }
}

交易类

/**
 * 交易单
 * Created by liuguoquan on 2017/4/28.
 */
public class Transaction {

    private Trader trader;
    private int year;
    private int value;

    public Transaction(Trader trader, int year, int value) {
        this.trader = trader;
        this.year = year;
        this.value = value;
    }

    public Trader getTrader() {
        return trader;
    }

    public void setTrader(Trader trader) {
        this.trader = trader;
    }

    public int getYear() {
        return year;
    }

    public void setYear(int year) {
        this.year = year;
    }

    public int getValue() {
        return value;
    }

    public void setValue(int value) {
        this.value = value;
    }

    @Override
    public String toString() {
        return "Transaction{" +
                "trader=" + trader +
                ", year='" + year + '\'' +
                ", value=" + value +
                '}';
    }
}

计算

public class TransactionProcess {

    public static void main(String[] args) {

        Trader liu = new Trader("Lau","Beijing");
        Trader lee = new Trader("Lee","Shanghai");
        Trader zhang = new Trader("Zhang","Guangzhou");
        Trader wang = new Trader("Wang","Beijing");

        List<Transaction> transactions = Arrays.asList(
                new Transaction(liu,2016,300),
                new Transaction(lee,2015,100),
                new Transaction(lee,2016,500),
                new Transaction(zhang,2016,9000),
                new Transaction(wang,2017,1000),
                new Transaction(liu,2016,1500)
        );

        // (1) 找出2016年发生的全部交易，并按交易额排序（从低到高）。
        transactions.stream().filter(t -> t.getYear() == 2016)
                .sorted(Comparator.comparing(Transaction::getValue))
                .collect(Collectors.toList());

        // (2) 交易员都在哪些不一样的城市工做过？
        transactions.stream().map(t -> t.getTrader().getCity())
                .distinct()
                .collect(Collectors.toList());

        // (3) 查找全部来自于北京的交易员，并按姓名排序。
        transactions.stream().map(t -> t.getTrader())
                .filter(t -> t.getCity().equals("Beijing"))
                .distinct()
                .sorted(Comparator.comparing(Trader::getName))
                .collect(Collectors.toList());

        // (4) 返回全部交易员的姓名字符串，按字母顺序排序。
        transactions.stream().map(t -> t.getTrader())
                .map(t -> t.getName())
                .distinct()
                .sorted()
                .collect(Collectors.toList());

        // (5) 有没有交易员是在深圳工做的？
        boolean isExist = transactions.stream().anyMatch(t -> t.getTrader().getCity().equals("Shenzhen"));
        if (isExist) {
            System.out.println("有在深圳工做的");
        } else {
            System.out.println("没有在深圳工做的");
        }

        // (6) 打印生活在北京的交易员的全部交易额。
        int sum = transactions.stream().filter(t -> t.getTrader().getCity().equals("Beijing"))
                .map(t -> t.getValue())
                .reduce(0,Integer::sum);
        System.out.println(sum);

        // (7) 全部交易中，最高的交易额是多少？
        int max = transactions.stream().map(t -> t.getValue())
                .reduce(0,Integer::max);
        System.out.println(max);

        // (8) 找到交易额最小的交易。
        int min = transactions.stream().map(t -> t.getValue())
                .reduce(0,Integer::min);
        System.out.println(min);
    }
}

小结

  • 中间操做表

操做 类型 返回类型 目的
filter 中间操做 Stream<T> 过滤元素
distinct 中间操做 Stream<T> 过滤重复的元素
skip 中间操做 Stream<T> 跳过指定数量的元素
limit 中间操做 Stream<T> 限制元素的数量
map 中间操做 Stream<T> 流的转化
flatmap 中间操做 Stream<T> 流的扁平化
sorted 中间操做 Stream<T> 元素排序

  • 终端操做表

操做 类型 返回类型 目的
forEach 终端操做 void 消费流中的每一个元素，返回void
count 终端操做 long 返回流中元素的个数，返回long
collect 终端操做 R 把流归约为一个集合
anyMatch 终端操做 boolean 流中是否有符合要求的元素
noneMatch 终端操做 boolean 流中是否没有任何符合要求的元素
allMatch 终端操做 boolean 流中是否全部元素都是符合要求的
findAny 终端操做 Optional<T> 查找符合要求的元素
findFirst 终端操做 Optional<T> 查找第一个符合要求的元素
reduce 终端操做 Optional<T> 归约
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程