5

有没有正确的方法为集合中的每个元素打开资源，而不是使用流 api，使用资源做一些 map()、filter()、peek() 等，然后关闭资源？

我有这样的事情： 

List<String> names =  getAllNames();
names.stream().map(n -> getElementFromName(n))
              .filter(e -> e.someCondition())
              .peek(e -> e.doSomething())
              .filter(e -> e.otherCondition())
              .peek(e -> e.doSomethingElse())
              .filter(e -> e.lastCondition())
              .forEach(e -> e.doTheLastThing());

这应该可以正常工作，除了我在 getElementFromName 方法中打开一个资源（例如数据库连接）。然后我在 someCondition 或 doSomething 等其他实例方法中使用该资源。而且我不知道如何正确关闭它。

我知道，我只在流上使用中间操作。这意味着，所有方法都在 forEach 操作中进行评估，并且性能应该没问题，因为迭代只进行一次。

但我不知道如何关闭为 getElementFromName 方法中的每个元素打开的资源。

我可以保存由 getElementFromName 创建的所有元素的列表并稍后关闭资源。但我只会浪费空间，让所有资源保持活力。也将通过元素列表进行第二次迭代。在这种情况下，这使得避免使用流 api 更可取。那么有没有办法在我使用完元素后以某种方式自动关闭资源？

我也知道，可以使用 foreach lopp 轻松完成，我只是好奇是否可以使用流 api 完成。

4

2 回答 2

3

您可以flatMap为此使用：

.flatMap(n -> {
    YourResource r = getElementFromName(n);
    return Stream.of(r).onClose(r::close);
})

这里假设返回元素封装的资源有close()方法。如果不是，代码会变得更复杂，但图片应该很清楚。您返回的不仅仅是返回单个对象，而是返回一个单元素流，其onClose操作会进行必要的清理。如果它可以抛出检查异常，您还必须为此添加一个处理程序，最好将异常包装在未经检查的异常中。

这依赖于以下方面的保证flatMap：

每个映射流都closed在其内容被放入该流之后。

但总的来说，这段代码，尤其是peek的过度使用，看起来非常可疑。

于 2019-04-18T14:26:42.103 回答
0

您可以创建第二个列表来存储遇到的元素。不幸的是，这是我所知道的使用流关闭所有元素的唯一方法。

在这个例子中，我将假设getElementFromName返回一个类型的对象Element：

List<Element> elements = new ArrayList<>(); // Or whatever kind of list you want
List<String> names =  getAllNames();
names.stream().map(n -> getElementFromName(n))
              .peek(e -> elements.add(e)) // Add the elements to the list
              .filter(e -> e.someCondition())
              .peek(e -> e.doSomething())
              .filter(e -> e.otherCondition())
              .peek(e -> e.doSomethingElse())
              .filter(e -> e.lastCondition())
              .forEach(e -> e.doTheLastThing());

elements.forEach(e -> e.close()); // Close all the elements
于 2019-04-17T22:43:13.197 回答