C++实现简单的异步心跳检测机制 _ 定时器与Lambda回调任务【源码】-C++-PHP中文网

心跳检测不能只用 std::this_thread::sleep_for，因其阻塞休眠会卡死线程、无法响应中断、处理断连或并发任务；正确做法是用 std::jthread + std::stop_token 实现非阻塞、可取消、带上下文的心跳。

c++实现简单的异步心跳检测机制 _ 定时器与lambda回调任务【源码】

心跳检测为什么不能只用 std::this_thread::sleep_for

因为阻塞式休眠会卡死整个线程，无法响应中断、无法及时处理网络断连、也无法在同一个线程里并发执行其他任务（比如收包、日志、状态更新）。真实场景下，心跳必须是「非阻塞 + 可取消 + 带上下文」的。

正确做法是用 std::thread 配合 std::condition_variable 或更现代的 std::jthread（C++20）+ std::stop_token；或者借助异步定时器抽象（如封装 std::chrono + std::function）。

用 std::jthread 可自动 join + 支持主动停止，避免资源泄漏
心跳回调必须捕获必要上下文（如 socket fd、连接 ID），否则 Lambda 闭包里访问野指针是常见崩溃源
不要在回调里做耗时操作（如磁盘写入、复杂计算），否则会拖慢定时精度，建议只发信号或投递到队列

如何用 std::jthread + std::chrono 实现可取消心跳

C++20 的 std::jthread 天然支持协作式中断，配合 std::stop_token 能安全退出循环。核心逻辑是：每次 tick 前检查是否已被请求停止。

class Heartbeat {
    std::jthread thread_;
    std::function<void> on_timeout_;

public:
    Heartbeat(std::function<void> cb, int interval_ms)
        : on_timeout_(std::move(cb)) {
        thread_ = std::jthread([this, interval_ms](std::stop_token stoken) {
            while (!stoken.stop_requested()) {
                if (on_timeout_) on_timeout_();
                // 等待 interval_ms，但可被 stop_token 中断
                std::this_thread::sleep_for(
                    std::chrono::milliseconds(interval_ms));
            }
        });
    }

    ~Heartbeat() = default; // jthread 自动 join
};</void></void>

构造即启动，析构自动停止并等待线程结束，无需手动管理生命周期
std::this_thread::sleep_for 在收到 stop 请求后会提前返回，不会卡死
如果回调需要访问对象成员，Lambda 必须按值捕获 shared_from_this() 或确保对象生命周期长于线程

Lambda 回调里访问 this 指针的典型陷阱

直接在 Lambda 里捕获 this 是危险的——若 Heartbeat 对象在定时器触发前就销毁了，回调执行时就会访问已释放内存。

解决方法只有两个：要么延长对象生命周期（如用 std::shared_ptr 管理），要么把心跳逻辑抽离为无状态函数。

C++14

C++14 对 C++11 的修正与增强版本，适合旧系统维护和较老工具链兼容。

下载

推荐方式：让使用者传入 std::shared_ptr，并在 Lambda 中按值捕获它：[conn = shared_from_this()](){ conn->sendPing(); }
错误写法：[this](){ this->sendPing(); } —— 无任何生命周期保护
如果心跳只是发个 UDP 包且不依赖对象状态，干脆传裸函数指针或 std::function 带连接 ID 参数