Java Stream API 操作完全攻略：让你的代码更加出色 (四)

阿里云国内75折回扣微信号：monov8

阿里云国际，腾讯云国际，低至75折。AWS 93折免费开户实名账号代冲值优惠多多微信号：monov8 飞机：@monov6

前言

Java Stream 是一种强大的数据处理工具，可以帮助开发人员快速高效地处理和转换数据流。使用 Stream 操作可以大大简化代码，使其更具可读性和可维护性，从而提高开发效率。本文将为您介绍 Java Stream 操作的所有方面，包括 range、range、iterate、generate 等操作，让你的代码行云流水，更加优雅。

range()：生成一个包含指定范围内所有整数的 Stream。
rangeClosed()：生成一个包含指定范围内所有整数（包括端点）的 Stream。
iterate()：根据指定的初始值和 UnaryOperator 生成一个无限长度的 Stream。
generate()：根据指定的 Supplier 生成一个无限长度的 Stream。
takeWhile()：返回满足指定条件的元素，直到遇到第一个不满足条件的元素。
dropWhile()：返回不满足指定条件的元素，直到遇到第一个满足条件的元素。
peek()：对每个元素执行指定的操作，但并不消费元素。
boxed()：将 Stream 中的基本类型元素装箱成对应的包装类型。
parallel()：返回一个并行的 Stream。
sequential()：返回一个顺序的 Stream。

示例

1. 使用 range()：生成一个包含指定范围内所有整数的 Stream。

代码示例：

import java.util.stream.IntStream;

public class RangeExample {
    public static void main(String[] args) {
        IntStream.range(1, 6)
                 .forEach(System.out::println);
    }
}

输出结果：

2. 使用 rangeClosed()：生成一个包含指定范围内所有整数（包括端点）的 Stream。

代码示例：

import java.util.stream.IntStream;

public class RangeClosedExample {
    public static void main(String[] args) {
        IntStream.rangeClosed(1, 5)
                 .forEach(System.out::println);
    }
}

输出结果：

3. 使用 iterate()：根据指定的初始值和 UnaryOperator 生成一个无限长度的 Stream。

代码示例：

import java.util.stream.Stream;

public class IterateExample {
    public static void main(String[] args) {
        Stream.iterate(2, n -> n * 2)
              .limit(5)
              .forEach(System.out::println);
    }
}

输出结果：

4. 使用 generate()：根据指定的 Supplier 生成一个无限长度的 Stream。

代码示例：

import java.util.Random;
import java.util.stream.Stream;

public class GenerateExample {
    public static void main(String[] args) {
        Stream.generate(() -> new Random().nextInt(100))
              .limit(5)
              .forEach(System.out::println);
    }
}

输出结果：

5. 使用 takeWhile()：返回满足指定条件的元素，直到遇到第一个不满足条件的元素。

代码示例：

import java.util.stream.Stream;

public class TakeWhileExample {
    public static void main(String[] args) {
        Stream.of("apple", "banana", "orange", "pear")
              .takeWhile(s -> s.startsWith("a"))
              .forEach(System.out::println);
    }
}

输出结果：

apple

6. 使用 dropWhile()：返回不满足指定条件的元素，直到遇到第一个满足条件的元素。

代码示例：

import java.util.stream.Stream;

public class DropWhileExample {
    public static void main(String[] args) {
        Stream.of("apple", "banana", "orange", "pear")
              .dropWhile(s -> s.startsWith("a"))
              .forEach(System.out::println);
    }
}

输出结果：

banana
orange
pear

7. 使用 peek()：对每个元素执行指定的操作，但并不消费元素。

代码示例：

import java.util.stream.Stream;

public class PeekExample {
    public static void main(String[] args) {
        Stream.of("apple", "banana", "orange", "pear")
              .peek(System.out::println)
              .count();
    }
}

输出结果：

apple
banana
orange
pear

8. 使用 boxed()：将 Stream 中的基本类型元素装箱成对应的包装类型。

代码示例：

import java.util.stream.IntStream;

public class BoxedExample {
    public static void main(String[] args) {
        IntStream.range(1, 6)
                 .boxed()
                 .forEach(System.out::println);
    }
}

输出结果：

9. 使用 parallel()：返回一个并行的 Stream。

代码示例：

import java.util.stream.Stream;

public class ParallelExample {
    public static void main(String[] args) {
        Stream.of("apple", "banana", "orange", "pear")
              .parallel()
              .forEach(System.out::println);
    }
}

输出结果：

pear
banana
apple
orange

10. 使用 sequential()：返回一个顺序的 Stream。

代码示例：

import java.util.stream.Stream;

public class SequentialExample {
    public static void main(String[] args) {
        Stream.of("apple", "banana", "orange", "pear")
              .parallel()
              .sequential()
              .forEach(System.out::println);
    }
}

输出结果：