std::jthread是C++20引入的现代化线程类，位于头文件中，其“j”代表joining，意味着在线程对象析构时会自动调用join()，避免资源泄漏。相比std::thread，std::jthread不仅提供自动合流能力，还内置了协作式中断机制，通过std::stop_token、std::stop_source和std::stop_callback支持安全的线程取消。使用时只需将可调用对象传入jthread构造函数，若需中断支持，则函数或lambda需接收std::stop_token作为第一参数，并在执行中定期检查stop_requested()状态。调用request_stop()后，关联的stop_token会通知任务退出，同时可注册stop_callback进行资源清理。因此，在C++20及以上版本中应优先使用std::jthread以提升并发编程的安全性与简洁性。
在C++20中，std::jthread 是对 std::thread 的现代化改进，它不仅具备自动合流（join）的能力，还内置了线程中断机制，使得并发编程更安全、更简洁。相比传统线程管理方式，jthread 能有效避免资源泄漏和死锁问题。
什么是 std::jthread？
std::jthread（joining thread）是 C++20 引入的新类型，位于 头文件中。它的“j”代表“joining”，意味着在线程对象析构时会自动调用 join()，无需手动管理生命周期。
jthread 还整合了 std::stop_token、std::stop_source 和 std::stop_callback，支持安全的协作式中断机制——这是传统 std::thread 所不具备的关键能力。
基本用法：替代 std::thread
使用 jthread 和使用 thread 非常相似，但更安全：
立即学习“C++免费学习笔记（深入）”；
#include #include #include void task() { for (int i = 0; i < 5; ++i) { std::this_thread::sleep_for(std::chrono::milliseconds(100)); std::cout << "Working... " << i << "n"; }}int main() { std::jthread t(task); // 自动 join，无需 t.join() t.join(); // 可显式调用，也可省略 return 0;}
即使你忘记调用 join()，jthread 析构时也会自动完成，防止程序终止时报错。
线程中断：协作式取消
jthread 最大的优势是支持中断。通过 stop_token 检查是否收到停止请求，实现安全退出。
#include #include #include void cancellable_task(std::stop_token stoken) { for (int i = 0; i < 100; ++i) { if (stoken.stop_requested()) { std::cout << "Task cancelled.n"; return; } std::this_thread::sleep_for(std::chrono::milliseconds(50)); std::cout << "Step " << i << "n"; } std::cout << "Task completed.n";}int main() { std::jthread t(cancellable_task); std::this_thread::sleep_for(std::chrono::milliseconds(300)); t.request_stop(); // 请求中断 return 0;}
在这个例子中，cancellable_task 接收一个 std::stop_token 参数。调用 t.request_stop() 后，stop_token 会感知到请求，任务可据此退出循环。
使用 lambda 支持中断
你也可以在 lambda 中使用 stop_token：
std::jthread t([](std::stop_token stoken) { while (!stoken.stop_requested()) { std::cout << "Running...n"; std::this_thread::sleep_for(std::chrono::seconds(1)); } std::cout << "Lambda task stopped.n";});std::this_thread::sleep_for(std::chrono::seconds(3));t.request_stop();
注意：lambda 必须接受 std::stop_token 作为第一个参数，运行时系统会自动传入。
stop_callback：清理资源
你可以注册回调函数，在中断请求发出时执行清理操作：
std::jthread t([](std::stop_token stoken) { std::stop_callback guard(stoken, []{ std::cout << "Cleaning up resources...n"; }); while (!stoken.stop_requested()) { std::cout << "Processing...n"; std::this_thread::sleep_for(std::chrono::milliseconds(200)); }});std::this_thread::sleep_for(std::chrono::milliseconds(600));t.request_stop();
当 request_stop() 被调用时，guard 的回调会触发，适合关闭文件、释放内存等操作。
基本上就这些。std::jthread 让 C++ 并发更现代、更安全。它把自动合流和中断机制集成在一起，显著减少了出错可能。如果你用的是 C++20 或更高版本，优先选择 jthread 而不是 thread。不复杂但容易忽略的是：确保可中断函数正确接收 stop_token 并定期检查状态。这样你的多线程代码才能真正响应外部控制。
以上就是C++怎么使用C++20的std::jthread_C++并发编程与可中断线程的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1486339.html
微信扫一扫 
支付宝扫一扫 
