std::stop_callback提供轻量无锁的协作式取消机制,通过stop_token绑定回调,在request_stop时同步执行清理;需确保其生命周期覆盖整个任务时段,推荐结合jthread自动管理,并避免重复注册或跨线程析构。

一、理解 std::stop_callback 的协作取消机制
当异步任务在多个线程中运行,且需响应外部请求提前终止时,std::stop_callback 提供了一种轻量、无锁的回调注册方式,用于在 stop_source 发出停止信号后自动触发用户定义的清理逻辑。该机制依赖于 std::stop_token 的状态轮询与回调绑定,不强制中断执行流,而是由任务主动检查并退出。
1、声明一个 std::stop_source 对象,用于发出停止请求。
2、通过 stop_source.get_token() 获取关联的 std::stop_token 实例。
3、构造 std::stop_callback 对象,传入 stop_token 和一个可调用对象(如 lambda 或函数对象)。
4、一旦 stop_source.request_stop() 被调用,所有已注册且未销毁的 stop_callback 实例将被同步调用(在 request_stop 所在线程上下文中)。
二、确保回调执行时机与生命周期安全
std::stop_callback 的析构会自动注销回调,因此其生存期必须严格覆盖可能触发 stop 的整个时段;若回调对象在 stop_token 仍有效时提前销毁,对应清理逻辑将不会执行,导致资源泄漏或状态不一致。
1、将 std::stop_callback 声明为栈对象,并确保其作用域延伸至任务函数返回前。
2、避免将其存储于动态分配内存中且未受智能指针管理,否则可能因 delete 先于 request_stop 导致漏回调。
3、在多线程环境下,确认 stop_callback 实例的构造与析构仅发生在单一线程内,防止跨线程析构引发未定义行为。
三、使用 lambda 捕获局部资源实现自动释放
借助 lambda 表达式按值捕获堆分配资源(如 std::unique_ptr)或共享状态(如 std::shared_ptr),可在 stop_callback 触发时自动释放资源,无需显式编写析构逻辑,提升代码安全性与可读性。
1、在异步任务函数内部,创建 std::unique_ptr
2、构造 stop_callback 时,使用 [&ptr] 或 [ptr = std::move(ptr)] 捕获该指针。
3、在 lambda 主体中执行资源清理操作,例如 close()、unmap() 或标记为无效状态。
4、确保 lambda 中对捕获变量的访问是线程安全的,尤其避免对非原子共享变量进行无同步写入。
四、配合 std::jthread 实现自动注册与分离
std::jthread 内置 stop_source 并在析构时自动调用 request_stop(),其构造过程中可通过 get_stop_token() 获取 token 并注册 stop_callback,从而形成“启动即注册、结束即触发”的闭环模型。
1、声明 std::jthread t([](std::stop_token stoken) { /* 任务主体 */ });
2、在任务主体开头,立即构造 std::stop_callback cb(stoken, []{ /* 清理动作 */ });
3、在任务循环中定期检查 stoken.stop_requested(),并在为 true 时跳出循环。
4、当 t 被销毁或主动调用 t.request_stop(),cb 将在其析构前被调用,此时任务函数尚未退出,可安全访问局部变量和栈对象。
五、避免常见误用:重复注册与条件竞争
同一 stop_token 可多次构造 stop_callback,但每个实例独立管理;若未注意作用域或重复构造而未保留对象,可能导致同一清理逻辑被多次执行或完全遗漏,尤其在异常路径下易出错。
1、禁止在循环体内反复构造未命名的 std::stop_callback,例如 for(...) { std::stop_callback(stoken, f); }。
2、若需动态控制回调启用/禁用,应使用命名变量并复用其赋值,而非重建实例。
3、在异常抛出路径中,确认 stop_callback 对象能随栈展开正确析构,否则需在 catch 块中显式调用 request_stop 并手动触发等效清理。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











