ASIO正确处理多线程+strand+socket+timer

The*_*orm 5 c++ boost-asio asio server

我正在使用最新的 ASIO 版本(截至目前 1.18.0)。目前正在设计一个带有计时器(用于超时)的多线程异步 TCP 服务器。我有一个io_context有多个线程调用其run()函数的单个线程。我接受这样的新连接:

void Server::AcceptConnection()
{
    acceptor_.async_accept(asio::make_strand(io_context_),
            [this](const asio::error_code& error, asio::ip::tcp::socket peer) {
                if (!error) {
                    std::make_shared<Session>(std::move(peer))->run();
                }
                AcceptConnection();
            });
}
Run Code Online (Sandbox Code Playgroud)

这是该类的精简版本Session

class Session : public std::enable_shared_from_this<Session>
{
public:
    Session(asio::ip::tcp::socket&& peer) : peer_(std::move(peer)) {}
    void run()
    {
        /*
        asio::async_read(peer_, some_buffers_, some_callback_);
        timeout_timer_.expires_after();
        timeout_timer_.async_wait();
        // etc
        */
    }
    
private:
    asio::ip::tcp::socket peer_;
    asio::steady_timer timeout_timer_{peer_.get_executor()};
}
Run Code Online (Sandbox Code Playgroud)

请注意定时器的初始化。另外,请注意,我没有对套接字和计时器的异步处理程序使用任何类型的strand::wrap()asio::bind_executor()包装器,因为据我了解,如果我使用正确的执行程序初始化对象,则不再需要它们。

这里的问题是:这是在 TCP 连接正在使用的同一链内使用计时器来处理链内 TCP 连接的正确方法吗?

注意:计时器用于在超时后中止 TCP 连接。

seh*_*ehe 5

是的,这也是我使用新界面编写内容的方式。

我记得当我开始使用新界面时也有同样的担忧,并最终检查各种完成处理程序是否确实在预期的链上运行,它们确实这样做了。

总而言之,这些极大地简化了库的使用。