Java8流并尝试使用资源

Question

我认为流API在这里是为了使代码更易于阅读。我觉得有点烦。流接口扩展了java。lang.AutoCloseable接口。

因此，如果你想正确地关闭流，你必须使用try-with资源。

清单1.不是很好，流没有关闭。

public void noTryWithResource() {
    Set<Integer> photos = new HashSet<Integer>(Arrays.asList(1, 2, 3));

    @SuppressWarnings("resource") List<ImageView> collect = photos.stream()
        .map(photo -> new ImageView(new Image(String.valueOf(photo))))
        .collect(Collectors.<ImageView>toList());
}

清单2.使用2嵌套try

public void tryWithResource() {
    Set<Integer> photos = new HashSet<Integer>(Arrays.asList(1, 2, 3));

    try (Stream<Integer> stream = photos.stream()) {
        try (Stream<ImageView> map = stream
                .map(photo -> new ImageView(new Image(String.valueOf(photo)))))
        {
            List<ImageView> collect = map.collect(Collectors.<ImageView>toList());
        }
    }
}

清单3。当map返回流时，必须关闭stream（）和map（）函数。

public void tryWithResource2() {
    Set<Integer> photos = new HashSet<Integer>(Arrays.asList(1, 2, 3));

    try (Stream<Integer> stream = photos.stream(); Stream<ImageView> map = stream.map(photo -> new ImageView(new Image(String.valueOf(photo)))))
    {
        List<ImageView> collect = map.collect(Collectors.<ImageView>toList());
    }
}

我举的例子毫无意义。为了示例，我将jpg图像的路径替换为整数。但不要让这些细节分散你的注意力。

使用这些可自动关闭的流的最佳方式是什么。我不得不说，我对我展示的3个选项中的任何一个都不满意。你怎么认为？还有其他更优雅的解决方案吗？

Answer 1

“可关闭”的意思是“可以关闭”，而不是“必须关闭”。

过去是这样的，例如，请参阅ByteArrayOutputStream：

通过tearrayoutputstream关闭。

现在，这对于流是正确的，文档中明确指出：

Streams有一个BaseStream.close（）方法并实现AutoCloseable，但几乎所有的流实例在使用后实际上并不需要关闭，一般只有源为IO通道的流（如Files.lines（Path， Charset）返回的流）才会需要关闭。

因此，如果审计工具生成错误警告，那是审计工具的问题，而不是API的问题。

注意，即使要添加资源管理，也不需要嵌套try语句。虽然以下内容足够：

final Path p = Paths.get(System.getProperty("java.home"), "COPYRIGHT");
try(Stream<String> stream=Files.lines(p, StandardCharsets.ISO_8859_1)) {
    System.out.println(stream.filter(s->s.contains("Oracle")).count());
}

您还可以将辅助流添加到资源管理中，而无需额外的try：

final Path p = Paths.get(System.getProperty("java.home"), "COPYRIGHT");
try(Stream<String> stream=Files.lines(p, StandardCharsets.ISO_8859_1);
    Stream<String> filtered=stream.filter(s->s.contains("Oracle"))) {
    System.out.println(filtered.count());
}

Answer 2

只有当流需要自己进行任何清理（通常是I/O）时，才需要关闭流。您的示例使用哈希集，因此它不需要关闭。

来自Stream javadoc：

通常，只有源为IO通道的流（如Files.lines（Path， Charset）返回的流）才需要关闭。大多数流由集合、数组或生成函数支持，不需要特殊的资源管理。

因此，在您的示例中，这应该可以正常工作

List<ImageView> collect = photos.stream()
                       .map(photo -> ...)
                       .collect(toList());

编辑

即使您需要清理资源，您也应该能够只使用一次资源试用。假设您正在读取一个文件，其中文件中的每一行都是图像的路径：

 try(Stream<String> lines = Files.lines(file)){
       List<ImageView> collect = lines
                                  .map(line -> new ImageView( ImageIO.read(new File(line)))
                                  .collect(toList());
  }

Answer 3

您正在使用@SuppressWarnings（"资源"），它可能会抑制有关未关闭资源的警告。这不是javac发出的警告之一。网络搜索似乎表明，如果AutoCloseable未关闭，Eclipse会发出警告。

根据引入自动关闭的Java 7规范，这是一个合理的警告：

不再需要时必须关闭的资源。

然而，AutoCloseable的Java 8规范被放宽，以删除“必须关闭”子句。它现在部分地说，

可能包含资源的对象。。。直到它关闭。

基类实现AutoCloseable是可能的，事实上也是常见的，即使不是它的所有子类或实例都包含可释放的资源。对于必须完全通用地运行的代码，或者当知道AutoCloseable实例需要资源释放时，建议使用资源尝试结构。但是，当使用同时支持基于I/O和非基于I/O的表单的工具（如Stream）时，使用非基于I/O的表单时，资源尝试块通常是不必要的。

Lambda专家组广泛讨论了这个问题；此消息总结了决策。除其他事项外，它提到了对可自动关闭规范（上文引用）和基流规范（其他答案引用）的更改。它还提到可能需要为更改的语义调整Eclipse代码检查器，可能不会无条件地为可自动关闭的对象发出警告。显然，这条消息没有传到Eclipse的人那里，或者他们还没有改变它。

总之，如果Eclipse警告导致您认为需要关闭所有可自动关闭的对象，那么这是不正确的。只有某些特定的可自动关闭的对象需要关闭。Eclipse需要修复（如果尚未修复）不为所有可自动关闭的对象发出警告。