C++ 如何利用 std::stop_source 优雅终止复杂的生产者消费者任务【干货】-C++-PHP中文网

std::stop_source仅发送停止请求，任务能否优雅退出取决于生产者/消费者是否在循环内频繁检查std::stop_token::stop_requested()并主动响应；否则线程可能永久挂起。

c++ 如何利用 std::stop_source 优雅终止复杂的生产者消费者任务【干货】

std::stop_source 本身不能直接“终止任务”，它只负责发送停止请求；能否优雅退出，完全取决于你的生产者/消费者是否主动轮询 std::stop_token 并响应。

为什么 std::stop_token::stop_requested() 必须在循环内频繁检查

这是最容易被忽略的致命点：std::stop_source 发出请求后，不会中断线程执行，也不会自动抛异常。所有阻塞、计算、IO 操作都照常运行，直到你显式检查 token.stop_requested() 并主动退出。

常见错误场景：

生产者在 while (!done) { produce(); sleep(100ms); } 中用布尔变量控制，完全忽略 token → 无法响应停止
消费者卡在 queue.pop()（无超时）上，且 pop 内部不接受 std::stop_token → 线程永久挂起

正确做法是把检查嵌入最外层循环，并尽量靠近阻塞点：

while (!token.stop_requested()) {
    auto item = queue.wait_pop(token); // 自定义支持 token 的阻塞弹出
    if (token.stop_requested()) break;
    consume(item);
}

std::condition_variable::wait_until 配合 stop_token 实现可中断等待

标准 std::condition_variable 不原生支持 std::stop_token，但你可以用 wait_until + 轮询实现等效效果，避免无限等待。

关键不是“替换为新 API”，而是“让等待有出口”：

不要用 cv.wait(lock, []{ return !queue.empty(); }); —— 它不响应 stop
改用 cv.wait_until(lock, deadline, [&]{ return !queue.empty() || token.stop_requested(); });
每次唤醒后，先检查 token.stop_requested()，再决定继续等待还是退出

注意 deadline 建议设为 “当前时间 + 100ms”，而非远期时间，否则可能延迟响应停止请求。

C++14

C++14 对 C++11 的修正与增强版本，适合旧系统维护和较老工具链兼容。

下载

如何让自定义队列的 pop/wait_pop 支持 stop_token

标准 std::queue 不支持 std::stop_token，必须自己封装或选用支持协作取消的同步原语（如 boost::sync_queue 或 moodycamel::ConcurrentQueue 手动配合轮询）。

最小可行封装要点：

pop 方法签名应为 T wait_pop(std::stop_token token)
内部使用 std::condition_variable::wait_until，每次等待前检查 token.stop_requested()
若等待超时且 token.stop_requested() 为真，直接 throw std::stop_token::stop_requested() 或返回空 std::optional<t></t>
避免在锁内做耗时操作，尤其是调用用户代码前必须已释放锁

示例片段（简化）：

std::optional<t> wait_pop(std::stop_token token) {
    std::unique_lock lk{mtx};
    while (q.empty() && !token.stop_requested()) {
        cv.wait_until(lk, std::chrono::steady_clock::now() + 100ms,
                      [&]{ return !q.empty() || token.stop_requested(); });
    }
    if (token.stop_requested()) return std::nullopt;
    auto item = std::move(q.front()); q.pop();
    return item;
}</t>