std::stop_token不能直接stop,因其仅为观察者,真正触发终止的是std::stop_source;协作式终止需由发起方调request_stop(),工作线程轮询stop_requested()或注册回调响应。

std::stop_token 为什么不能直接 stop?
它只是个“观察者”,不是“控制器”——std::stop_token 本身没有 stop() 方法,真正能触发终止的是对应的 std::stop_source。常见错误是拿到 std::jthread 的 get_stop_token() 后试图调它的 stop(),结果编译报错:error: 'class std::stop_token' has no member named 'stop'。
协作式终止必须由发起方(比如主线程)调用 stop_source.request_stop(),工作线程通过轮询 stop_token.stop_requested() 或注册回调来响应。
- 每个
std::jthread自带一个std::stop_source,可通过get_stop_source()获取(C++20 起) - 普通
std::thread不自带停止机制,需手动传入std::stop_source或共享的std::stop_source -
std::stop_token是轻量、可拷贝、可跨线程传递的;std::stop_source可移动,但通常只在创建处持有
std::jthread 构造时捕获 token 的典型误用
很多人以为构造 std::jthread 时把 std::stop_token 当参数传进去就能“绑定”,其实不行——std::jthread 的构造函数不接受 std::stop_token,它只在内部自动关联自己的 stop_source。你传进去的 token 如果来自别处,和该线程毫无关系。
正确做法是:让线程函数接收 std::stop_token 参数,并在启动时用 std::jthread 的隐式绑定机制传入(它会自动把自身的 token 注入):
立即学习“C++免费学习笔记(深入)”;
std::jthread t([](std::stop_token st) {
while (!st.stop_requested()) {
// 工作逻辑
std::this_thread::sleep_for(100ms);
}
// 清理
});
- lambda 参数类型必须是
std::stop_token(或const std::stop_token&),否则自动注入失效 - 如果函数是普通函数指针或 functor 类,需确保其第一个参数是
std::stop_token,且参数数量匹配 - 不要在 lambda 内部再调
t.get_stop_token()—— 那是另一个对象,且可能已失效
stop_callback 在析构时机上容易被忽略
std::stop_callback 的生命周期绑定到其 std::stop_token 所属的 std::stop_source。一旦 stop_source 被销毁(比如 std::jthread 结束并析构),所有关联的 stop_callback 会立即被调用(如果还没调过),然后析构。
这意味着:如果你在栈上创建 std::stop_callback,而它捕获了局部变量,就得确保回调执行时这些变量还活着——否则就是悬垂引用。更安全的做法是把它作为类成员,或确保回调只做轻量、无状态操作(如设置标志位):
std::jthread t([&done](std::stop_token st) {
std::stop_callback cb(st, [&done] { done = true; }); // OK:cb 和 done 生命周期匹配
while (!st.stop_requested()) {
// ...
}
});
-
std::stop_callback构造即注册,析构即注销;重复注册不会报错,但只有最后一个有效 - 回调函数不能抛异常,否则引发
std::terminate - 回调执行在线程上下文中(即请求 stop 的那个线程),不是在线程自身上下文里
与条件变量配合时的唤醒遗漏风险
很多场景下线程阻塞在 std::condition_variable::wait 上,此时仅靠检查 stop_token 是不够的——它可能永远等不到通知,也就没机会轮询 stop_requested()。必须配合 wait 的谓词重载或使用 wait_until 做超时轮询。
推荐写法是把 stop_token 和条件变量一起用,利用 wait 的 predicate 版本自动检查终止请求:
std::jthread t([st = std::stop_token{}, &cv, &data, &ready](std::stop_token s) mutable {
st = s;
std::unique_lock lk{mutex};
cv.wait(lk, [&] { return st.stop_requested() || ready; });
if (st.stop_requested()) return;
// 处理 data...
});
- 不能只依赖
cv.wait(lk)(无谓词),否则 stop 请求来了也无法退出等待 - 使用
wait_for+ 手动检查stop_requested()也行,但谓词方式更简洁、不易漏判 - 注意
std::stop_token是可移动的,传给 lambda 时若需跨多层捕获,建议用值捕获后mutable修改
最麻烦的不是怎么写,而是忘记在所有可能阻塞的地方插入 stop 检查——尤其是嵌套调用、第三方库 IO、或自定义 wait 函数里。token 本身不强制中断,全靠你主动问它“该停了吗”。










