C++ std::jthread使用详解

#include <thread>
#include <iostream>
#include <chrono>

void worker() {
    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(worker); // 自动启动线程
    // 不需要 t.join()，析构时会自动 join
    return 0;
}

#include <thread>
#include <iostream>
#include <chrono>

void cancellable_worker(std::stop_token stoken) {
    for (int i = 0; i < 100; ++i) {
        if (stoken.stop_requested()) {
            std::cout << "Stop requested! Exiting gracefully.\n";
            return;
        }
        std::this_thread::sleep_for(std::chrono::milliseconds(50));
        std::cout << "Loop " << i << "\n";
    }
}

int main() {
    std::jthread t(cancellable_worker);

    std::this_thread::sleep_for(std::chrono::milliseconds(200));
    t.request_stop(); // 请求线程停止

    // 析构时自动 join
    return 0;
}

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 thread stopped.\n";
});

std::this_thread::sleep_for(std::chrono::seconds(3));
t.request_stop();

std::cout << "Thread ID: " << t.get_id() << "\n";