Java Stream forEach、filter和distinct的使用

1、forEach的使用

Stream()方法返回串行流，返回的Stream是根据当前数据的顺序进行遍历，parallelStream()方法返回并行流，并行能提高运行效率，但不能确保执行的顺序，如下，

import java.util.*;import java.util.stream.Collectors;import java.util.stream.Stream;public class Main {   public static class Person {        int age;        Person (int age) {            this.age = age;        }        public int getAge() {            return age;        }        public void setAge(int age) {            this.age = age;        }  }public static void main(String[] args) {    List list1 = Arrays.asList(new Person(11),new Person(22), new Person(33), new Person(44), new Person(55));    //串行遍历    list1.stream().forEach(o->{       System.out.println("stream() ："+o.getAge());    });        List list2 = Arrays.asList(new Person(66),new Person(77), new Person(88), new Person(89), new Person(99));    //并行遍历    list2.parallelStream().forEach(o->{       System.out.println("parallelStream() ："+o.getAge());    });    System.exit(0); //success  }}

2、filter的使用

使用filter()可以根据指定条件，筛选出我们需要获取的数据，如下，

import java.util.*;import java.util.stream.Collectors;import java.util.stream.Stream;public class Main {   public static class Person {        int age;        Person (int age) {            this.age = age;        }        public int getAge() {            return age;        }        public void setAge(int age) {            this.age = age;        }  }public static void main(String[] args) {    List numbers = Arrays.asList(12, 74, 5, 8, 16);    numbers.stream().filter(n -> n > 10).forEach(System.out::println);    List list1 = Arrays.asList(new Person(11),new Person(22), new Person(33), new Person(44), new Person(55));    list1.stream().filter(p -> p.getAge() < 40).forEach(f -> System.out.println("getAge(): "+f.getAge()));        System.exit(0); //success  }}

相关文档：Java Stream使用多个过滤器(filter)或复杂条件方法用法及简单写法代码

3、使用distinct去除重复数据

distinct()内部是调用equals方法，对比对象的值需要重写equals方法，否则只是比较引用值。

import java.util.*;import java.util.stream.Collectors;import java.util.stream.Stream;public class Main {   public static class Person {        int age;        Person (int age) {            this.age = age;        }        public int getAge() {            return age;        }        public void setAge(int age) {            this.age = age;        }    @Override    public boolean equals(Object o) {        if (this == o) return true;        if (o == null || getClass() != o.getClass()) return false;        Person p = (Person) o;        return p.getAge() == this.age;    }     @Override    public int hashCode() {        return Objects.hash(age);    }  }public static void main(String[] args) {    List numbers = Arrays.asList(16, 8, 12, 74, 5, 8, 16);    numbers.stream().distinct().forEach(System.out::println);    List list1 = Arrays.asList(new Person(11),new Person(22), new Person(33), new Person(44), new Person(22),  new Person(55),  new Person(55));    list1.stream().distinct().forEach(f -> System.out.println("getAge(): "+f.getAge()));        System.exit(0); //success  }}