Java 流操作

Java流 – Java流操作

常用的流操作如下列出。

• Distinct
  中间操作
  通过检查equals()方法返回由不同元素组成的流。
• filter
  中间操作
  返回与指定谓词匹配的流。
• flatMap
  中间操作
  生成流扁平化。
• limit
  中间操作
  按数字截断流。
• map
  中间操作
  对流执行一对一映射
• peek
  中间操作
  应用调试的操作。
• skip
  中间操作
  丢弃前n个元素并返回剩余流。如果此流包含少于请求的流，则返回空流。
• sorted
  中间操作
  根据自然顺序或指定的比较器对流进行排序。对于有序流，排序是稳定的。
• allMatch
  终端操作
  如果流中的所有元素都匹配指定的谓词，则返回true，否则返回false。如果流为空，则返回true。
• anyMatch
  终端操作
  如果流中的任何元素与指定的谓词匹配，则返回true，否则返回false。如果流为空，则返回false。
• findAny
  终端操作
  返回流中的任何元素。返回空流的一个空的Optional对象。
• findFirst
  终端操作
  返回流的第一个元素。对于有序流，它返回第一个元素;对于无序流，它返回任何元素。
• noneMatch
  终端操作
  如果流中没有元素匹配指定的谓词，则返回true，否则返回false。如果流为空，则返回true。
• forEach
  终端操作
  对流中的每个元素应用操作。
• reduce
  终端操作
  应用缩减操作以从流计算单个值。

流 Peek

我们可以使用Stream <T>接口的窥探（Consumer<？super T>action）方法调试流。

IntStream，LongStream和DoubleStream还包含一个peek()方法，它接受IntConsumer，LongConsumer和DoubleConsumer作为参数。

我们可以使用带有peek()方法的lambda表达式来记录元素。

以下代码使用peek()方法打印通过流管道的元素：

import java.util.stream.Stream;

public class Main {
  public static void main(String[] args) {
    int sum = Stream.of(1, 2, 3, 4, 5)
        .peek(e -> System.out.println("Taking integer: " + e))
        .filter(n -> n % 2 == 1)
        .peek(e -> System.out.println("Filtered integer: " + e))
        .map(n -> n * n).peek(e -> System.out.println("Mapped integer: " + e))
        .reduce(0, Integer::sum);
    System.out.println("Sum = " + sum);

  }
}

上面的代码生成以下结果。

流 ForEach

forEach操作对流的每个元素执行操作。

Stream<T> 接口包含两种方法来执行forEach操作:

void  forEach(Consumer<? super  T> action)
void  forEachOrdered(Consumer<? super  T> action)

IntStream，LongStream和DoubleStream包含相同的方法。

forEach()方法不保证操作的顺序应用流中的每个元素。

forEachOrdered()方法按元素的顺序执行操作由流定义。

forEachOrdered()方法可能会减慢并行流中的处理速度。

以下代码打印员工列表中的女性详细信息:

import java.time.LocalDate;
import java.time.Month;
import java.util.Arrays;
import java.util.List;

public class Main {
  public static void main(String[] args) {

    Employee.persons()
            .stream()
            .filter(Employee::isFemale)
            .forEach(System.out::println);
  }
}

class Employee {
  public static enum Gender {
    MALE, FEMALE
  }

  private long id;
  private String name;
  private Gender gender;
  private LocalDate dob;
  private double income;

  public Employee(long id, String name, Gender gender, LocalDate dob,
      double income) {
    this.id = id;
    this.name = name;
    this.gender = gender;
    this.dob = dob;
    this.income = income;
  }
  public boolean isFemale() {
    return this.gender == Gender.FEMALE;
  }

  public static List<Employee> persons() {
    Employee p1 = new Employee(1, "Jake", Gender.MALE, LocalDate.of(1971,
        Month.JANUARY, 1), 2343.0);
    Employee p2 = new Employee(2, "Jack", Gender.MALE, LocalDate.of(1972,
        Month.JULY, 21), 7100.0);
    Employee p3 = new Employee(3, "Jane", Gender.FEMALE, LocalDate.of(1973,
        Month.MAY, 29), 5455.0);
    Employee p4 = new Employee(4, "Jode", Gender.MALE, LocalDate.of(1974,
        Month.OCTOBER, 16), 1800.0);
    Employee p5 = new Employee(5, "Jeny", Gender.FEMALE, LocalDate.of(1975,
        Month.DECEMBER, 13), 1234.0);
    Employee p6 = new Employee(6, "Jason", Gender.MALE, LocalDate.of(1976,
        Month.JUNE, 9), 3211.0);

    List<Employee> persons = Arrays.asList(p1, p2, p3, p4, p5, p6);

    return persons;
  }
}

上面的代码生成以下结果。

例2

以下代码显示如何使用forEach()方法将所有女性的收入增加10％。

import java.time.LocalDate;
import java.time.Month;
import java.util.Arrays;
import java.util.List;

public class Main {
  public static void main(String[] args) {
    List<Employee> persons = Employee.persons();
    System.out.println("Before increasing the   income:   " + persons);

    persons.stream()
           .filter(Employee::isFemale)
           .forEach(p -> p.setIncome(p.getIncome() * 1.10));

    System.out.println("After increasing the   income:   " + persons);
  }
}

class Employee {
  public static enum Gender {
    MALE, FEMALE
  }

  private long id;
  private String name;
  private Gender gender;
  private LocalDate dob;
  private double income;

  public Employee(long id, String name, Gender gender, LocalDate dob,
      double income) {
    this.id = id;
    this.name = name;
    this.gender = gender;
    this.dob = dob;
    this.income = income;
  }

  public Gender getGender() {
    return gender;
  }

  public boolean isMale() {
    return this.gender == Gender.MALE;
  }

  public boolean isFemale() {
    return this.gender == Gender.FEMALE;
  }

  public void setGender(Gender gender) {
    this.gender = gender;
  }
  public double getIncome() {
    return income;
  }

  public void setIncome(double income) {
    this.income = income;
  }

  public static List<Employee> persons() {
    Employee p1 = new Employee(1, "Jake", Gender.MALE, LocalDate.of(1971,
        Month.JANUARY, 1), 2343.0);
    Employee p2 = new Employee(2, "Jack", Gender.MALE, LocalDate.of(1972,
        Month.JULY, 21), 7100.0);
    Employee p3 = new Employee(3, "Jane", Gender.FEMALE, LocalDate.of(1973,
        Month.MAY, 29), 5455.0);
    Employee p4 = new Employee(4, "Jode", Gender.MALE, LocalDate.of(1974,
        Month.OCTOBER, 16), 1800.0);
    Employee p5 = new Employee(5, "Jeny", Gender.FEMALE, LocalDate.of(1975,
        Month.DECEMBER, 13), 1234.0);
    Employee p6 = new Employee(6, "Jason", Gender.MALE, LocalDate.of(1976,
        Month.JUNE, 9), 3211.0);

    List<Employee> persons = Arrays.asList(p1, p2, p3, p4, p5, p6);

    return persons;
  }

  @Override
  public String toString() {
    String str = String.format("(%s, %s,  %s,  %s,  %.2f)\n", id, name, gender,
        dob, income);
    return str;
  }
}

上面的代码生成以下结果。