C++项目中用标准库替代boost::this_thread::interruption_point()的方案咨询

首先得明确：C++标准库并没有直接对应boost::this_thread::interruption_point()的内置函数。这是因为Boost的线程中断是一套自己实现的协作式中断机制，而C++标准库的线程模型从设计上就没有提供内置的线程中断支持——标准库更倾向于让开发者手动实现协作式的线程终止逻辑。

不过，你可以手动模拟出类似Boost中断点的行为，核心思路是用协作式的标志检查来替代，具体步骤如下：

1. 实现自定义的中断检查机制 #

你可以用一个std::atomic<bool>类型的标志来标记线程是否需要中断，然后在原本调用interruption_point()的位置，检查这个标志：如果标志为true，就抛出一个自定义的异常（模拟Boost的boost::thread_interrupted异常），让线程自行终止。

示例代码 #

#include <atomic>
#include <stdexcept>
#include <thread>
#include <unordered_map>
#include <mutex>

// 自定义中断异常，对应Boost的thread_interrupted
struct thread_interrupted : std::runtime_error {
    thread_interrupted() : std::runtime_error("Thread interrupted") {}
};

// 存储所有线程的中断标志，用线程ID作为键
std::unordered_map<std::thread::id, std::atomic<bool>> thread_interrupt_map;
std::mutex interrupt_map_mutex;

// 替代boost::this_thread::interruption_point()的函数
void interruption_point() {
    std::lock_guard<std::mutex> lock(interrupt_map_mutex);
    auto it = thread_interrupt_map.find(std::this_thread::get_id());
    if (it != thread_interrupt_map.end() && it->second.load(std::memory_order_acquire)) {
        it->second.store(false, std::memory_order_release); // 重置标志
        throw thread_interrupted();
    }
}

// 用于触发指定线程的中断
void interrupt_thread(std::thread& t) {
    std::lock_guard<std::mutex> lock(interrupt_map_mutex);
    auto it = thread_interrupt_map.find(t.get_id());
    if (it != thread_interrupt_map.end()) {
        it->second.store(true, std::memory_order_release);
    }
}

// 注册当前线程的中断标志（线程启动时调用）
void register_thread_interrupt_flag() {
    std::lock_guard<std::mutex> lock(interrupt_map_mutex);
    thread_interrupt_map.emplace(std::this_thread::get_id(), false);
}

// 注销当前线程的中断标志（线程退出前调用）
void unregister_thread_interrupt_flag() {
    std::lock_guard<std::mutex> lock(interrupt_map_mutex);
    thread_interrupt_map.erase(std::this_thread::get_id());
}

// 示例线程函数
void worker_thread() {
    register_thread_interrupt_flag();
    try {
        while (true) {
            // 模拟耗时工作
            // ...

            // 插入中断检查点，对应原来的boost::this_thread::interruption_point()
            interruption_point();

            // 继续工作
            // ...
        }
    } catch (const thread_interrupted&) {
        // 处理中断，清理资源
        // ...
    }
    unregister_thread_interrupt_flag();
}

2. 关键注意事项 #

• 协作式中断：和Boost的机制一样，这种自定义方案也是协作式的——线程必须在合适的位置主动调用interruption_point()检查标志，否则无法触发中断。这符合C++标准库的设计理念，避免了强制中断可能带来的资源泄漏或未定义行为。
• 线程安全：示例中用互斥锁保护了存储线程标志的哈希表，确保跨线程操作时的线程安全，实际项目中可以根据场景调整同步策略。
• 灵活适配：你可以根据原有代码的逻辑，选择抛出自定义异常或者直接返回，只要保证线程能安全终止、资源能正确清理即可。

内容的提问来源于stack exchange，提问作者SPlatten