七爪源码:如何创建 Java 流 java创建文件流

创建 Java Stream 的 4 种流行方法

介绍

• Streams 是 Java 8 中添加的最重要的特性之一。
• Streams 允许 Java 开发人员将集合转换为元素流并定义中间和终端操作。 基本上，它赋予了开发人员更多的权力，可以用更少的行数和更多的声明性来编写简洁优雅的代码。
• 在本文中，我们将探索从不同数据源创建 Java 流的各种方法。

从值创建流

流接口由两个静态方法组成，我们可以将单个对象或对象集合传递给它们。

Stream<String> stream1 = Stream.of("test1");
Stream<String> stream2 = Stream.of("test1", "test2", "test3", "test1");

一旦我们有了流，我们就可以使用中间和终端操作。
以下是我们可以对流执行的一些操作。

我想只过滤从 stream2 到输出的不同元素。

stream2
        .distinct()
        .forEach(System.out::println);

Streams 接口还提供了从 Builder 模式创建流。

Stream<Integer> build1 = Stream.<Integer>builder()
        .add(2)
        .add(1)
        .add(3)
        .add(5)
        .build();

从数组创建流

数组是任何编程语言中最常见的数据结构。 我们将 Arrays 数据源转换为 Java 流。

String[] domains = {"abc.com", "pqr.net", "tuf.org", "abc.com"};

我们有一系列域数据源。 现在让我们从中创建流，以便我们可以使用漂亮的函数式编程。

Stream<String> domainsStream = Stream.of(domains);

现在让我们看看如何从原始元素创建流。

为了从原始数组创建流，我们必须使用 IntStream 类型。 Arrays 类提供流方法来将基元转换为 IntStream。

int[] ints = {1,2,3};
IntStream stream = Arrays.stream(ints);
Arrays.stream(ints).forEach(System.out::println);

从函数创建流

我们还可以从无限的数字序列创建流。 Streams 接口提供了 generate() 和 iterate() 等方法，可用于创建无限的数字序列。

使用 generate(Supplier<? extends T> s)：

• 正如我们所见， generate 以供应商为参数来生成无限的数字序列。
• 每次调用 generate 时，我们都从 UUID 类传递 randomUUID 方法来生成唯一的 id。 我们将结果限制为 10 并打印结果。

Stream
        .generate(UUID::randomUUID)
        .limit(10)
        .forEach(System.out::println);

使用迭代(T Seed, UnaryOperator<T> f)

迭代方法可以根据顺序生成无限序列。 在下面的示例中，我们传递了单元运算符，该运算符采用当前元素并增加 1。

Stream
        .iterate(10, n->n+1)
        .limit(10)
        .forEach(System.out::println);

如果我们在这里使用并行流，我们可能无法获得所需的流，因为可能不遵守顺序。

从集合创建

Collection 接口提供了 stream 和 parallelStream 方法来创建流形式的 Collection。

Set<Integer> set = new HashSet<>(List.of(3,2,1));
System.out.println(set.
        stream().
        sorted().
        reduce(Integer::max));

从文件 IO 创建流

Java NIO File 类和 BufferedReader 还提供了来自 lines() 方法的流。

// NIO Files.lines()
try (Stream<String> lines = Files.lines(Path.of(""))){
    System.out.println(lines);
}catch (Exception ex){
    System.out.println(ex);
}// bufferedreaderBufferedReader bufferedReader = new BufferedReader(new FileReader(""));
try(Stream<String> lines = bufferedReader.lines()){
    lines.forEach(System.out::println);
}catch (Exception ex){
    System.out.println(ex);
}

创建空流

我们还可以创建空流，如下所示。 当没有元素时，空流对于避免空指针异常很有用。

Stream<String> empty = Stream.empty();

结论

• 在本文中，我们讨论了从不同输入源（如集合、数组、IO 等）创建流的不同方法。
• Streams 提供了编写具有惰性操作评估的功能代码的机会。

关注七爪网，获取更多APP/小程序/网站源码资源！