c++ - boost::iostreams 管理资源

Question

我是 boost 及其 iostreams 包的新手，发现文档有点单薄。希望有人会让我直截了当。我正在尝试转换我不久前编写的一小段 C# 流代码，以便在压缩流中读取。

byte[] data = new byte[length - 1];
file.Read(data, 0, data.Length);

Stream ret = new ZlibStream(new MemoryStream(data), CompressionMode.Decompress, true);
return ret;

文件的一部分数据被读入内存缓冲区，该缓冲区提供给 zlib 解压缩器。随着时间的推移，流的使用者会选择它，当它完成时将调用 Close()，它与垃圾收集器结合将清理所有资源。 注意:一个重要的区别是我不是要解压整个文件，只是其中的一小部分。该文件已被搜索到某个内部位置，并且长度相对于文件的完整大小而言较小。

我正在尝试使用 Boost 在 C++ 代码中提出与此等效的最佳方法。到目前为止，我的道德等同于上述内容(未经测试):

char * data = new char[length - 1];
_file.read(data, length - 1);

io::stream_buffer<io::basic_array_source<char> > buffer(data, length - 1);

io::filtering_stream<io::input> * in = new io::filtering_stream<io::input>;         
in->push(io::zlib_decompressor());
in->push(buffer);

return in;

我假设我可以返回包装在 shared_ptr 中的 filtering_stream，这将使消费者不必担心删除流，但我也有新的数据缓冲区。理想情况下，我希望消费者只需在流上调用 close() ，一些机制(例如回调)将清理过滤器中的底层资源。要求消费者将流传递给显式释放函数也是可以接受的，但我仍然不完全确定如何首先取回底层数据缓冲区。

也欢迎更清洁的替代解决方案。

更新 1

我尝试粗略地捕获 Cat Plus Plus 关于 std::vector-backed 驱动程序的评论。这不是我所做的，但这是我到目前为止所想出的。在下面的代码中，我有一个基于 boost 驱动程序示例的 boost::shared_array-backed 驱动程序。

namespace io = boost::iostreams;

class shared_array_source
{
public:

    typedef char            char_type;
    typedef io::source_tag  category;

    shared_array_source (boost::shared_array<char> s, std::streamsize n)
        : _data(s), _pos(0), _len(n)
    { }

    std::streamsize read (char * s, std::streamsize n)
    {
        std::streamsize amt = _len - _pos;
        std::streamsize result = (std::min)(amt, n);

        if (result != 0) {
            std::copy(_data.get() + _pos, _data.get() + _pos + result, s);
            return result;
        }
        else {
            return -1;
        }
    }

private:
    boost::shared_array<char> _data;
    std::streamsize _pos;
    std::streamsize _len;
};

然后我有返回流的函数

io::filtering_istream * GetInputStream (...)
{
    // ... manipulations on _file, etc.

    boost::shared_array<char> data(new char[length - 1]);
    _file.read(data.get(), length - 1);

    shared_array_source src(data, length - 1);
    io::stream<shared_array_source> buffer(src);

    io::filtering_istream * in = new io::filtering_istream;
    in->push(io::zlib_decompressor());
    in->push(buffer);

    // Exhibit A
    // uint32_t ui;
    // rstr->read((char *)&ui, 4);

    return in;
}

在我的测试程序的主要功能中:

int main () {
    boost::iostreams::filtering_istream * istr = GetInputStream();

    // Exhibit B
    uint32_t ui;
    rstr->read((char *)&ui, 4);

    return 0;
}

请忽略我正在返回一个永远不会被释放的指针这一事实——我尽量保持简单。当我运行这个时会发生什么？如果我取消注释 Exhibit A 中的代码，我会在 ui 中得到正确的读数。但是当我遇到 Exhibit B 时，我在 Boost 中深深地、深深地、深深地崩溃了(有时)。好吧，废话，我超出了范围，东西坏了，一定是一些本地人在解构，把一切都搞砸了。 data在shared_array中，in在heap上，compressor根据docs构建。

boost 构造函数或函数之一是否在获取对堆栈上对象的引用(即 io::stream 或 filtering_stream 的推送)？如果是这样的话，我有点回到原点，堆上有未管理的对象。

Answer 1

你真的应该避免在堆上分配任何东西。 filtering_stream 可以即时解压缩，因此您无需先更换缓冲区或读取文件内容。代码应该更像这样:

io::filtering_stream stream;
stream.push(io::zlib_decompressor());
stream.push(_file);

如果你真的需要在堆上分配它，那么是的，你应该把它包装在一个智能指针中(但同样，不要先读取文件数据——你有该缓冲区的泄漏，更不用说以这种方式读取大文件的效率可能非常低)。