std::stop_callback是C++20协作取消机制的核心组件,通过绑定stop_token实现停止请求触发时自动执行回调,需配合stop_token轮询与生命周期管理确保线程安全退出。

一、理解 std::stop_callback 的协作取消机制
当多个线程协同执行异步任务时,主线程可能需要向工作线程发出取消请求,而工作线程需在安全点响应并退出。std::stop_callback 提供了一种在 stop_token 关联的停止请求触发时自动执行回调的机制,其本质是注册一个函数对象,在 std::stop_source 发出停止信号后,由系统确保该回调在关联的执行上下文中被调用。该机制不强制终止线程,仅提供通知能力,要求用户代码主动检查 stop_token 状态并配合退出。
1、定义 std::stop_source 实例以控制停止状态。
2、从 stop_source 获取 std::stop_token 并传递给工作线程或异步任务函数。
3、在目标线程中构造 std::stop_callback 对象,绑定一个无参可调用对象作为回调函数。
4、回调函数将在 stop_source.request_stop() 被调用且该 token 尚未被放弃时,于回调构造所在线程(非 necessarily 工作线程)执行。
二、在工作线程中注册 stop_callback 并轮询检查
为确保跨线程取消响应及时且不破坏资源安全性,可在工作线程入口处注册 stop_callback,并在循环中持续检查 stop_token 的 stop_requested() 状态。该方式将回调注册与轮询结合,既利用回调实现即时通知,又通过轮询保障取消点覆盖所有关键路径。
1、在线程函数开始处声明 std::stop_token token 参数并接收传入的 token。
2、声明 std::stop_callback cb{token, [&] { /* 清理逻辑 */ }}; 其中捕获局部变量需注意生命周期。
3、在主处理循环内插入 if (token.stop_requested()) break; 判断语句。
4、循环退出后执行显式资源释放,如关闭文件句柄、释放堆内存、解除锁等。
三、使用 std::jthread 自动绑定 stop_source 与线程生命周期
std::jthread 是 C++20 引入的可协作中断线程类型,其构造时自动关联 std::stop_source,并在析构时调用 request_stop();同时支持将 stop_token 直接传入线程函数。该特性大幅简化了跨线程取消的样板代码,避免手动管理 stop_source 生命周期错位风险。
1、声明 std::jthread jt{[](std::stop_token st) { /* 工作逻辑 */ }};
2、在 lambda 内部直接使用 st.stop_requested() 进行轮询判断。
3、无需显式构造 std::stop_callback,因 jthread 析构会自动触发所有已注册回调。
4、若需额外清理动作,可在 lambda 末尾或通过独立 std::stop_callback 注册,但必须确保回调捕获的对象在 jthread 存续期内有效。
四、避免 stop_callback 构造时悬挂引用或提前析构
std::stop_callback 的回调函数若捕获局部变量或 this 指针,而对应对象在其注册线程退出后已被销毁,则回调执行时将引发未定义行为。因此必须严格约束回调生命周期与所捕获对象生命周期的一致性。典型错误是在线程栈上构造 stop_callback 并捕获栈变量,随后线程结束导致回调持有所谓“悬垂引用”。
1、将回调所需数据封装为 shared_ptr 管理的对象,并在回调中按值捕获该 shared_ptr。
2、若在类成员函数中注册,应使用 weak_ptr
3、禁止在临时作用域(如 if 分支、for 循环体)内构造 std::stop_callback 并捕获局部变量。
4、所有被捕获对象的生存期必须严格长于 std::stop_callback 对象本身。
五、在异步操作中嵌入 stop_token 检查点
对于长时间运行的异步操作(如网络 I/O、文件读写、密集计算),不能仅依赖 stop_callback 的一次性通知,而应在操作内部设置多个细粒度检查点。这些检查点需调用 token.stop_requested() 并在返回 true 时立即中止当前操作,释放已分配资源,并返回 std::nullopt 或抛出 std::stop_token::stop_requested() 异常(若约定异常传播)。
1、将 stop_token 作为参数注入异步函数签名,例如 void async_read(file_handle h, buffer& b, std::stop_token st)。
2、在每次系统调用前插入 if (st.stop_requested()) return;
3、对分块处理的数据结构,在每块处理完成后检查一次 stop_token。
4、禁止在阻塞系统调用内部等待 stop_token —— 必须使用支持取消的非阻塞接口或超时重试机制。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











