C++中std::stop_token怎么停止线程_C++20优雅请求线程终止方法【同步】-C++-PHP中文网

std::stop_token 仅是观察者，不能停止线程；真正触发停止的是 std::jthread 析构或 request_stop()，线程函数必须主动轮询 stop_requested() 并配合 stop_callback 打破阻塞。

c++中std::stop_token怎么停止线程_c++20优雅请求线程终止方法【同步】

std::stop_token 本身不能停止线程

std::stop_token 只是一个“观察者”，它不触发停止，也不调用任何终止逻辑。它只提供一种方式让线程**主动轮询**是否被请求停止。真正发起停止的是 std::jthread 的析构或显式调用 request_stop() —— 此时关联的 std::stop_source 状态变为 stop_requested，stop_token::stop_requested() 才会返回 true。

常见错误是以为构造一个 std::stop_token 就能“控制”线程，结果线程照常运行到底。关键在于：线程函数内部必须检查 token，且外部必须有机制（如 std::jthread 自动析构）去触发请求。

仅靠 std::stop_token + 普通 std::thread 无法实现协作式停止（因为普通 std::thread 没绑定 std::stop_source）
std::jthread 在构造时自动关联一个 std::stop_source，其 get_stop_token() 返回的 token 才有意义
线程函数若未检查 token，即使外部调用了 request_stop()，该线程也不会响应

用 std::jthread + stop_token 实现同步等待终止

最典型的同步场景是：主线程希望“等线程做完当前任务后干净退出”。这需要线程函数在循环中定期检查 stop_token::stop_requested()，并在为 true 时跳出循环、完成清理、自然返回。

示例结构如下：

C函数速查手册（CHM版）

下载

std::jthread worker([](std::stop_token stoken) {
    while (!stoken.stop_requested()) {
        // 执行一段工作（比如处理一个队列项）
        if (auto item = queue.pop(); item.has_value()) {
            process(*item);
        } else {
            std::this_thread::sleep_for(10ms); // 避免忙等
        }
    }
    // 这里可做退出前清理（如 flush 日志、释放资源）
});

lambda 参数 std::stop_token 由 std::jthread 自动传入，与内部 stop_source 绑定
必须在循环条件或关键检查点调用 stoken.stop_requested()，不能只在开头查一次
std::jthread 析构时自动调用 request_stop() 并 join()，所以无需手动管理生命周期
若需提前终止，直接调用 worker.request_stop()，随后它会在下次轮询时退出

stop_callback 能帮你避免轮询但不解决同步阻塞

如果线程卡在某个不可中断的系统调用（如 read()、accept() 或无超时的 std::condition_variable::wait()），单纯轮询 stop_requested() 无效——它根本没机会检查。

此时可用 std::stop_callback 注册一个回调，在 request_stop() 被调用时**异步触发**，例如关闭 socket、通知条件变量：

std::jthread server([](std::stop_token stoken) {
    int sock = socket(...);
    std::stop_callback cb(stoken, [sock] { close(sock); }); // 请求停止时立即关 socket

    while (!stoken.stop_requested()) {
        struct sockaddr_in addr;
        socklen_t len = sizeof(addr);
        int client = accept(sock, (struct sockaddr*)&addr, &len); // 可能阻塞
        if (client == -1 && errno == EINTR) continue; // 被信号中断，重试
        if (client > 0) handle_client(client);
    }
});

std::stop_callback 构造即注册，析构自动注销；它不阻塞，只是“发个通知”
它不能替代轮询，而是配合使用：回调负责打破阻塞，轮询负责决定何时彻底退出
注意回调中不要做耗时或可能抛异常的操作（标准要求回调必须是 noexcept）

别忽略 stop_token 的拷贝语义和空状态

std::stop_token 是可拷贝、可移动的轻量对象，但它的“有效性”依赖于原始 std::stop_source 是否还存在。一旦 std::jthread 析构，其内部 stop_source 销毁，所有从它派生的 token 都变成“空状态”（stop_possible() == false，stop_requested() == false）。