使用 asio 和 C++11 在接受或接收时优雅地停止线程以进行阻塞或非阻塞

Question

我正在将 asio 用于 tcp 服务器，我也计划将 C++11 std 用于线程。我的最终目标是在 Linux 上拥有此应用程序，但我首先使用 Visual Studio 2015 在 Windows 上对其进行测试。

首先我使用阻塞，所以我发现有关于如何停止等待接受的线程的讨论。有 pre-C++11 解决方案，例如 pipe 和 select。我正在寻找asio方式。

    asio::io_service io_service;
    tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 13));
    backAcceptor = &acceptor;
    tcp::socket socket(io_service);

    asio::error_code ec;
    acceptor.accept(socket, &ec);

第二种方法是使用异步，但我更喜欢只使用 asio 标头。编译抱怨 asio::placeholder 没有这个成员，但根据评论，应用了解决方案：

    asio::async_write(socket_, asio::buffer(message_),
        std::bind(&tcp_connection::handle_write, shared_from_this(),
            std::placeholders::_1,
            std::placeholders::_2
            ));

run() 仍然阻塞在那里。我正在寻找从 main 恢复这个线程的方法。

    asio::io_service io_service;
    tcp_server server(io_service);
    io_service.run();

第三种方式是设置超时here。但这并不能阻止我的接受。另外，答案是在 2012 年。我希望现在有新的解决方案。

更新

为了测试场景，我首先有一个线程在同步accept() 或异步run() 处阻塞。当线程运行时，main 等待 2 秒，并尝试停止线程。然后我等待线程使用 join 完成。

对于第一种方法“Synchronous”，我尝试使用acceptor.cancel() 并且线程到达了join。这是正确的方法吗？

第二种方法“异步”，虽然我还不清楚如何正式停止这个线程，但我成功使用io_service.stop()实际取消了它。

请让我知道我的解决方案是否正确，我会继续尝试不同的解决方案。

Answer 1

我碰巧用run_one 和没有线程的非典型方法玩过，它特别允许您超时单个“非异步”操作：

• boost::asio + std::future - Access violation after closing socket

事实上，您确实发布了异步操作，但随后您调用 await_operation 并超时：

async_connect(socket, ip::tcp::resolver(ioservice).resolve({address, port}), raise());
await_socket(std::chrono::seconds(6));

这相当于执行同步connect 但可能会超时。没有线程、阻塞run() 或其他小狗受到伤害。

查看演示的链接答案

---

PS。如果您不希望 high_resolution_timer 与 std::chrono 很好地配合使用，请使用 deadline_timer 和 posix_time