C++怎么使用C++20的std::jthread_C++并发编程与可中断线程

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 非常相似，但更安全：

#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 并定期检查状态。这样你的多线程代码才能真正响应外部控制。

# 回调函数 # ai # c++ # ios # stream # 并发编程 # 构造函数 # 循环 # Lambda # 线程 # 多线程 # Thread # 并发 # 对象 # 的是 # 死锁 # 回调 # 定期检查 # 这是 # 头文件 # 也会 # 在这个 # 你可以 # 第一个

返回目录在线咨询

上一篇：基于JavaScript实现百度搜索框效果
下一篇：四川网站开发如何实现高效创新？

您的项目需求

*请认真填写需求信息，我们会在24小时内与您取得联系。