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

Question

我有一个函数，它创建一个新的网桥对象，并将其存储为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 future作为一个具有文件作用域的静态变量移到类之外，那么所有内容都会被正确地释放，但有时会出现"mutex destroyed which busy"错误。

如果我不将异步调用分配给任何东西，那么当超出函数的范围时，它就会阻塞，从而无法使用它

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

很抱歉出现了令人困惑的代码——我尽可能地精简了它来说明这个问题。

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; });