关闭 Stream 是否会关闭 BufferedReader 源？

Question

来自the docs：

Streams 有一个 BaseStream.close() 方法并实现 AutoCloseable， 但几乎所有流实例实际上都不需要关闭 使用后。通常，只有源为 IO 通道的流（例如 因为 Files.lines(Path, Charset)) 返回的那些将需要关闭。 大多数流由集合、数组或生成器支持 功能，不需要特殊的资源管理。 （如果一个流 确实需要关闭，它可以声明为一个资源 try-with-resources 语句。）

当我在BufferedReader 上使用lines() 方法创建Stream<String> 时，如下所示，关闭Stream 是否也会关闭BufferedReader？

try (Stream<String> lines = new BufferedReader(new InputStreamReader(process.getInputStream())).lines()) {
  // Do stuff
}

// Is the BufferedReader, InputStreamReader and InputStream closed?

我尝试过的一些非常快速的测试说不（BufferedReader 的in 字段不是null），但是我被下面的句子弄糊涂了，因为这个例子是 I/O嗯，对吧？

通常，只有源是 IO 通道的流（例如 因为 Files.lines(Path, Charset)) 返回的那些需要关闭。

如果没有，我是否需要关闭 两个 实例，或者关闭 BufferedReader 就足够了？

---

理想情况下，我想从某个方法返回一个Stream<String>，而不必让客户担心读者。目前，我创建了一个 Stream 装饰器，它也关闭了阅读器，但如果没有必要，它会更容易。

Answer 1

如果您想延迟关闭阅读器到交付的 Stream，您需要调用 Stream.onClose()：

static Stream<String> toStream(BufferedReader br){
    return br.lines().onClose(asUncheckedAutoCloseable(br));
}


static Runnable asUncheckedAutoCloseable(AutoCloseable ac) {
    return () -> {
        try {
            ac.close();
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    };
}

Answer 2

不，似乎没有。由于流是使用

创建的

    return StreamSupport.stream(Spliterators.spliteratorUnknownSize(
            iter, Spliterator.ORDERED | Spliterator.NONNULL), false);

不传递任何对BufferedReader的引用

Answer 3

在您的问题中，您没有展示您如何创建Reader，这是new BufferedReader(in) 的论点。但根据我自己的测试，没有理由假设 Stream 关闭了这个论点。

执行以下操作会关闭所有人：

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.io.Reader;
import java.util.stream.Stream;

public class SOPlayground {

    public static void main(String[] args) throws Exception {
        try (Reader in = new InputStreamReader(new FileInputStream(new File("/tmp/foo.html")));
                BufferedReader reader = new BufferedReader(in);
                Stream<String> lines = reader.lines()) {
            lines.forEach(System.out::println);
        }        
    }
}