0

我有一个创建新桥对象并将其存储为 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;
    }
}

在桥接类中有一个 std::future 变量在标头中定义并在桥接类方法中初始化：

//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() 循环之间执行工作。

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

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

如果我将 f_read 未来作为具有文件范围的静态变量移动到类外部，那么所有内容也都会正确释放，但有时我会收到“忙时销毁互斥锁​​”错误。

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

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

对不起，令人困惑的代码 - 我尽可能地压缩它来说明问题。

4

1 回答 1

2

你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; });
于 2019-01-14T10:00:16.367 回答