具有可关闭资源的Java Collector作为累加器

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了具有可关闭资源的Java Collector作为累加器，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2353字，纯文字阅读大概需要4分钟。

内容图文

假设我正在尝试创建一个收集器,将数据聚合到一个必须在使用后关闭的资源中.有没有办法在收集器中实现类似于finally块的东西？在成功的情况下,这可以在finisher方法中完成,但是在异常的情况下似乎没有调用任何方法.

目标是以干净的方式实现类似下面的操作,而不必首先将流收集到内存列表中.

stream.collect(groupingBy(this::extractFileName, collectToFile()));

解决方法:

我认为你能满足你的要求的唯一方法是通过提供给Stream.onClose方法的关闭处理程序.假设您有以下课程：

class CloseHandler implements Runnable {
    List<Runnable> children = new ArrayList<>();

    void add(Runnable ch) { children.add(ch); }

    @Override
    public void run() { children.forEach(Runnable::run); }
}

现在,您需要按如下方式使用您的流：

CloseHandler closeAll = new CloseHandler();
try (Stream<Something> stream = list.stream().onClose(closeAll)) {
    // Now collect
    stream.collect(Collectors.groupingBy(
        this::extractFileName, 
        toFile(closeAll)));
}

这使用try-with-resources构造,以便在使用时或发生错误时自动关闭流.请注意,我们将closeAll close处理程序传递给Stream.onClose方法.

下面是下游收集器的草图,它将收集/写入/发送元素到Closeable资源(请注意,我们还将closeAll关闭处理程序传递给它)：

static Collector<Something, ?, Void> toFile(CloseHandler closeAll) {

    class Acc {

        SomeResource resource; // this is your closeable resource

        Acc() {
            try {
                resource = new SomeResource(...); // create closeable resource
                closeAll.add(this::close);        // this::close is a Runnable
            } catch (IOException e) {
                throw new UncheckedIOException(e);
            }
        }

        void add(Something elem) {
            try {
                // TODO write/send to closeable resource here
            } catch (IOException e) {
                throw new UncheckedIOException(e);
            }
        }

        Acc merge(Acc another) {
            // TODO left as an exercise
        }

        // This is the close handler for this particular closeable resource
        private void close() {
            try {
                // Here we close our closeable resource
                if (resource != null) resource.close();
            } catch (IOException ignored) {
            }
        }
    }
    return Collector.of(Acc::new, Acc::add, Acc::merge, a -> null);
}

因此,它使用本地类(名为Acc)来包装可关闭资源,并声明方法将流的元素添加到可关闭资源,并且还合并两个Acc实例以防流并行(作为练习左侧) ,万一值得努力).

Collector.of用于根据Acc类的方法创建一个收集器,其中一个返回null的finisher,因为我们不想在Collectors.groupingBy创建的地图中放置任何东西.

最后,有close方法,它关闭包装的可关闭资源,以防它被创建.

当通过try-with-resources构造隐式关闭流时,将自动执行CloseHandler.run方法,这将依次执行创建每个Acc实例时先前添加的所有子关闭处理程序.

内容总结

以上是互联网集市为您收集整理的具有可关闭资源的Java Collector作为累加器全部内容，希望文章能够帮你解决具有可关闭资源的Java Collector作为累加器所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端