成员 std::future 阻止 boost::shared_ptr 超出范围

Question

我有一个创建新桥 object 并将其存储为 boost::shared_ptr:

的函数

bool proxy::bridge::acceptor::accept_connections() {
    try {
        session_ = boost::shared_ptr<bridge>(new bridge(io_service_));

        acceptor_.async_accept(session_->downstream_socket(),
            boost::bind(&acceptor::handle_accept,
                this, boost::asio::placeholders::error));
    }
    catch (std::exception& e) {
        std::cerr << e.what() << std::endl;
        return false;
    }

return true;
}

void proxy::bridge::acceptor::handle_accept(const boost::system::error_code& error) {
    if (!error) {
        session_->local_connect();
        if (!accept_connections()) {
        }
    }
    else {
        std::cerr << error.message() << std::endl;
    }
}

在桥 class 中是一个 std::future 变量，在 header 中定义并在桥 class 方法中初始化：

//proxy.h
std::mutex add_data_lock;
std::vector<int> global_resource_protected_by_lock;

class proxy {
    //...
    class bridge {
        //...
        std::future<void> f_read;
    };

    class acceptor {
         //...
    };
};

//proxy.cpp
void proxy::bridge::read(const boost::system::error_code& error, const size_t& bytes_transferred) {
    if (!error) {
        if (f_read.valid()) { f_read.wait(); }
        f_read = std::async(std::launch::async, std::bind(&proxy::bridge::handle_add_data, shared_from_this(), bytes_transferred));
    }
    else {
        close();
    }
}

void proxy::bridge::handle_add_data(const size_t& bytes_transferred) {
    add_data_lock.lock();
    //do work here
    add_data_lock.unlock();
}

void proxy::bridge::close() {
    //this is called when this object is no longer useful (ie. connection closed)

    if (f_read.valid()) { f_read.wait(); }

    //other closing functions...
}

重复调用 read() 方法 - 目标是异步调用 handle_add_data() 并在 read() 循环之间执行工作。

然而，动态创建的桥 object 即使在套接字关闭后也不会被删除（进程占用越来越多的内存）。

如果我将异步调用和 future 替换为对 handle_add_data() 的直接函数调用，则在调用 close() 时所有内容都会正确释放。

如果我将 f_read 未来移动到 class 之外作为具有文件范围的静态变量，那么所有内容也会正确释放，但有时我会收到 'mutex destroyed while busy' 错误.

如果我不将异步调用分配给任何东西，那么它会在超出函数范围时阻塞并破坏使用它的目的。

我应该怎么做才能在调用 close() 后正确删除动态创建的桥 object？

对于令人困惑的代码，我深表歉意 - 我已尽我所能对其进行了压缩以说明问题。

Answer 1

你的 bind 坚持 shared_ptr 的时间超过了它需要的时间。您可以将其更改为在完成时显式释放捕获的指针。

f_read = std::async(std::launch::async, [=, self = shared_from_this()]() mutable { self->handle_add_data(bytes_transferred); self = nullptr; });

在 C++14 之前，您需要作为被捕获的局部变量进行初始化

auto self = shared_from_this();
f_read = std::async(std::launch::async, [=]() mutable { self->handle_add_data(bytes_transferred); self = nullptr; });

成员 std::future 阻止 boost::shared_ptr 超出范围

Member std::future preventing boost::shared_ptr from going out of scope

c++

boost-asio

shared-ptr

stdasync