Безопасная отмена таймера дедлайна boost asio

Отмена безопасна.

Это просто не надежно. Вы не учли случай, когда таймер не был отложен. Тогда вы отмените его один раз, но он просто запустит новое асинхронное ожидание после вызова обработчика завершения.

Ниже приведены мои подробные шаги о том, как я отследил проблему.

РЕЗЮМЕ TL;DR

Отмена времени отменяет только асинхронные операции в полете.

Если вы хотите отключить цепочку асинхронных вызовов, вам придется использовать для этого дополнительную логику. Пример приведен ниже.

Отслеживание обработчика

Включение с

#define BOOST_ASIO_ENABLE_HANDLER_TRACKING 1

В результате получается вывод, который можно визуализировать с помощью boost/libs/asio/tools/handlerviz.pl:

Успешная трассировка

Как видите, async_wait находится в полете, когда происходит отмена.

«Плохой» след

(усечено, потому что это будет работать бесконечно)

Обратите внимание, как обработчик завершения видит cc=system:0, а не cc=system:125 (для operation_aborted). Это симптом того, что выложенная отмена на самом деле не "взяла". Единственное логическое объяснение (не видно на диаграмме) заключается в том, что таймер уже истек до того, как будет вызвана отмена.

Давайте сравним необработанные трассировки¹

¹ удаление шумовой разницы

Обнаружение

Итак, у нас есть зацепка. Можем ли мы это обнаружить?

    timer.get_io_service().post([](){
        std::cerr << "tid: " << std::this_thread::get_id() << ", cancelling in post\n";
        if (timer.expires_from_now() >= std::chrono::steady_clock::duration(0)) {
            timer.cancel();
        } else {
            std::cout << "PANIC\n";
            timer.cancel();
        }
    });

Отпечатки:

tid: 140113177143232, i: 0, waiting for thread to join()
tid: 140113177143232, i: 1, waiting for thread to join()
tid: 140113177143232, i: 2, waiting for thread to join()
tid: 140113177143232, i: 3, waiting for thread to join()
tid: 140113177143232, i: 4, waiting for thread to join()
tid: 140113177143232, i: 5, waiting for thread to join()
tid: 140113177143232, i: 6, waiting for thread to join()
tid: 140113177143232, i: 7, waiting for thread to join()
tid: 140113177143232, i: 8, waiting for thread to join()
tid: 140113177143232, i: 9, waiting for thread to join()
tid: 140113177143232, i: 10, waiting for thread to join()
tid: 140113177143232, i: 11, waiting for thread to join()
tid: 140113177143232, i: 12, waiting for thread to join()
tid: 140113177143232, i: 13, waiting for thread to join()
tid: 140113177143232, i: 14, waiting for thread to join()
tid: 140113177143232, i: 15, waiting for thread to join()
tid: 140113177143232, i: 16, waiting for thread to join()
tid: 140113177143232, i: 17, waiting for thread to join()
tid: 140113177143232, i: 18, waiting for thread to join()
tid: 140113177143232, i: 19, waiting for thread to join()
tid: 140113177143232, i: 20, waiting for thread to join()
tid: 140113177143232, i: 21, waiting for thread to join()
tid: 140113177143232, i: 22, waiting for thread to join()
tid: 140113177143232, i: 23, waiting for thread to join()
tid: 140113177143232, i: 24, waiting for thread to join()
tid: 140113177143232, i: 25, waiting for thread to join()
tid: 140113177143232, i: 26, waiting for thread to join()
PANIC

Можем ли мы сообщить о «суперотмене» другим, более ясным способом? У нас есть... только объект timer для работы, конечно:

Сигнализация отключения

У объекта timer не так много свойств для работы. Там нет close() или чего-то подобного, как в сокете, который можно использовать для перевода таймера в какое-то недопустимое состояние.

Однако есть момент истечения срока действия, и мы можем использовать специальное значение домена, чтобы сигнализировать о «недействительности» для нашего приложения:

timer.get_io_service().post([](){
    std::cerr << "tid: " << std::this_thread::get_id() << ", cancelling in post\n";
    // also cancels:
    timer.expires_at(Timer::clock_type::time_point::min());
});

Это «специальное значение» легко обрабатывать в обработчике завершения:

void handle_timeout(const boost::system::error_code& ec)
{
    if (!ec) {
        started = true;
        if (timer.expires_at() != Timer::time_point::min()) {
            timer.expires_from_now(std::chrono::milliseconds(10));
            timer.async_wait(&handle_timeout);
        } else {
            std::cerr << "handle_timeout: detected shutdown\n";
        }
    } 
    else if (ec != boost::asio::error::operation_aborted) {
        std::cerr << "tid: " << std::this_thread::get_id() << ", handle_timeout error " << ec.message() << "\n";
    }
}