c++ - 安全中断 C++11 阻塞操作

Question

我有一个 std::thread，它使用 Boost 的 asio 从串口读取数据:

std::atomic<bool> quit(false);

void serialThread()
{
    try
    {
        asio::io_service io;
        asio::serial_port port(io);

        port.open("COM9"); // Yeay no port enumeration support!

        port.set_option(asio::serial_port_base::baud_rate(9600));

        while (!quit)
        {
            asio::streambuf buf;
            asio::read_until(port, buf, "\n");

            auto it = asio::buffers_begin(buf.data());
            string line(it, it + buf.size());

            doStuffWithLine(line);
        }
    }
    catch (std::exception e)
    {
        cout << "Serial thread error: " << e.what() << endl;
    }
}

void SetupSignals()
{
    // Arrange it so that `quit = true;` happens when Ctrl-C is pressed.
}

int main(int argc, char *argv[])
{
    SetupSignals();

    thread st(serialThread);

    st.join();

    return 0;
}

当我按下 Ctrl-C 时，我想干净地退出线程，以便适本地调用所有析构函数(如果您不这样做，Windows 上的某些驱动程序会讨厌它适本地关闭他们的资源)。

不幸的是，如您所见，当前代码块在 read_until() 中，因此当您按下 Ctrl-C 时，在收到新的文本行之前什么都不会发生。

一种解决方案是使用轮询，如下所示:

asio::async_read_until(port, buf, "\n", ...);
while (!quit)
    io.poll();

但我宁愿不使用轮询。这很不雅观。我目前能看到的唯一解决方案是有一个 std::condition_variable quitOrIoFinished，它在 quit 设置为 true 或读取完成时触发。但是我没有写 asio，所以我不能给它一个条件变量来等待。

是否有任何干净、理智的解决方案？在 Go 中，我只使用 select 来等待多个 channel ，其中一个是退出 channel 。不过，我在 C++ 中看不到类似的解决方案。

Answer 1

使用 asio::signal_set 等待 INT 信号(control-C 倾向于发送中断)。

当它到达时，只需对具有未决异步操作的 IO 对象调用 cancel()。它们将返回 error_code 等于 boost::asio::error::operation_aborted。

现在，如果你有一个 io_service::work 对象，销毁它，所有运行 io_service::run() 的线程都会返回，这样你就可以加入它们.

注意 注意同步访问您的 IO 对象(例如，当您对它们调用 cancel() 时)因为这些对象不是线程安全的，与 io_service 和 strand。