由于超时而取消async_read

我正在尝试围绕async_read编写一个包装器同步方法，以允许在套接字上进行非阻塞读取。在互联网上的几个例子之后，我开发了一个解决方案，它似乎几乎是正确的，但不起作用。

该类声明以下相关属性和方法：

class communications_client
{
    protected:
        boost::shared_ptr<boost::asio::io_service> _io_service;
        boost::shared_ptr<boost::asio::ip::tcp::socket> _socket;
        boost::array<boost::uint8_t, 128> _data;
        boost::mutex _mutex;
        bool _timeout_triggered;
        bool _message_received;
        boost::system::error_code _error;
        size_t _bytes_transferred;
        void handle_read(const boost::system::error_code & error, size_t bytes_transferred);
        void handle_timeout(const boost::system::error_code & error);
        size_t async_read_helper(unsigned short bytes_to_transfer, const boost::posix_time::time_duration & timeout, boost::system::error_code & error);
        ...
}

方法async_read_helper是封装所有复杂性的方法，而其他两个handle_read和handle_timeout只是事件处理程序。以下是三种方法的实现：

void communications_client::handle_timeout(const boost::system::error_code & error)
{
    if (!error)
    {
        _mutex.lock();
        _timeout_triggered = true;
        _error.assign(boost::system::errc::timed_out, boost::system::system_category());
        _mutex.unlock();
    }
}
void communications_client::handle_read(const boost::system::error_code & error, size_t bytes_transferred)
{
    _mutex.lock();
    _message_received = true;
    _error = error;
    _bytes_transferred = bytes_transferred;
    _mutex.unlock();
}
size_t communications_client::async_read_helper(unsigned short bytes_to_transfer, const boost::posix_time::time_duration & timeout, boost::system::error_code & error)
{
    _timeout_triggered = false;
    _message_received = false;
    boost::asio::deadline_timer timer(*_io_service);
    timer.expires_from_now(timeout);
    timer.async_wait(
        boost::bind(
            &communications_client::handle_timeout,
            this,
            boost::asio::placeholders::error));
    boost::asio::async_read(
        *_socket,
        boost::asio::buffer(_data, 128),
        boost::asio::transfer_exactly(bytes_to_transfer),
        boost::bind(
            &communications_client::handle_read,
            this,
            boost::asio::placeholders::error,
            boost::asio::placeholders::bytes_transferred));
    while (true)
    {
        _io_service->poll_one();
        if (_message_received)
        {
            timer.cancel();
            break;
        }
        else if (_timeout_triggered)
        {
            _socket->cancel();
            break;
        }
    }
    return _bytes_transferred;
}

我的主要问题是：为什么这适用于_io_service->poll_one()上的循环，而没有循环并调用_io_service->run_one()？另外，我想知道对于更习惯使用Boost和Asio的人来说，它看起来是否正确。谢谢！

修复提案 #1

根据Jonathan Wakely的评论，可以在操作完成后使用_io_service->run_one()调用_io_service->reset()来替换循环。它应如下所示：

_io_service->run_one();
if (_message_received)
{
    timer.cancel();
}
else if (_timeout_triggered)
{
    _socket->cancel();
}
_io_service->reset();

经过一些测试，我已经检查了这种解决方案是否单独不起作用。handle_timeout方法被连续调用，错误代码为 operation_aborted 。如何停止这些呼叫？

修复提案#2

twsansbury的答案是准确的，并且基于坚实的文档基础。该实现导致async_read_helper中的以下代码：

while (_io_service->run_one())
{
    if (_message_received)
    {
        timer.cancel();
    }
    else if (_timeout_triggered)
    {
        _socket->cancel();
    }
}
_io_service->reset();

以及对handle_read方法的以下更改：

void communications_client::handle_read(const boost::system::error_code & error, size_t bytes_transferred)
{
    if (error != boost::asio::error::operation_aborted)
    {
        ...
    }
}

该解决方案在测试过程中已被证明是可靠和正确的。