调用std::condition_variable后应用因无效参数崩溃（多线程队列退出场景）

算力阿峰

2026-5-29

解决线程池退出时条件变量崩溃的问题

从你的崩溃堆栈来看，问题出在进程退出阶段CRT资源已经开始销毁，但你的全局队列processQueue的析构函数还在调用条件变量的相关操作——具体是销毁条件变量时内部触发了notify_all，但此时CRT的并发调度器已经处于不可用状态，导致访问无效资源崩溃。

你之前尝试的两种方案都没触达核心问题：用std::unique_ptr封装条件变量只是改变了它的生命周期管理方式，但没解决线程和CRT资源的销毁顺序；在析构里调用_endthreadex更是错误的，因为_endthreadex必须由线程自身调用，外部强行调用会导致CRT内部状态混乱。

正确的解决方案：优雅终止工作线程

核心思路是：先通知所有线程主动退出，等待它们全部结束后，再销毁队列等资源，避免进程退出时CRT资源和业务资源的销毁顺序冲突。

步骤1：修改MyQueue，添加停止机制

给队列增加一个原子停止标志，让线程能感知到退出信号，同时修改取元素的函数，在等待时同时检查停止状态：

#include <optional> // 需要C++17及以上，若版本较低可改用bool+额外返回值替代

class MyQueue {
private:
    std::queue<YourItemType> queue_;
    std::mutex mutex_;
    std::condition_variable cond_;
    std::atomic<bool> stop_flag_ = false; // 原子停止标志，确保跨线程可见性

public:
    // 修改取元素函数，返回std::optional表示是否有有效元素
    std::optional<YourItemType> get_next_item() {
        std::unique_lock<std::mutex> lock(mutex_);
        // 等待条件：队列非空 或者 收到停止信号
        while (queue_.empty() && !stop_flag_) {
            cond_.wait(lock);
        }

        if (stop_flag_) {
            return std::nullopt; // 收到停止信号，返回空
        }

        auto item = queue_.front();
        queue_.pop();
        return item;
    }

    void push_item(const YourItemType& item) {
        std::unique_lock<std::mutex> lock(mutex_);
        if (!stop_flag_) { // 停止后不再接受新元素
            queue_.push(item);
            lock.unlock();
            cond_.notify_one();
        }
    }

    // 触发停止：设置标志并唤醒所有等待的线程
    void stop() {
        std::unique_lock<std::mutex> lock(mutex_);
        stop_flag_ = true;
        lock.unlock();
        cond_.notify_all(); // 唤醒所有卡在wait的线程
    }
};

步骤2：修改工作线程函数，支持主动退出

让线程在收到停止信号时自行终止，并正确调用_endthreadex清理CRT资源：

unsigned int __stdcall WorkerThread(void* arg) {
    MyQueue* process_queue = static_cast<MyQueue*>(arg);
    
    while (true) {
        auto item_opt = process_queue->get_next_item();
        if (!item_opt.has_value()) {
            // 收到停止信号，退出循环
            break;
        }

        // 处理你的item逻辑...
        YourItemType& item = item_opt.value();
        // do something with item
    }

    // 由线程自身调用_endthreadex，正确清理CRT资源
    _endthreadex(0);
    return 0;
}

步骤3：应用退出时，先终止所有线程再清理资源

在应用的退出入口（比如main函数末尾、窗口的WM_CLOSE处理函数中），先触发队列停止，等待所有线程结束，再释放资源：

// 假设你保存了所有线程的句柄
std::vector<HANDLE> worker_thread_handles;

// 创建线程时保存句柄
for (int i = 0; i < 20; ++i) {
    HANDLE h_thread = (HANDLE)_beginthreadex(
        nullptr, 0, WorkerThread, &processQueue, 0, nullptr
    );
    if (h_thread != nullptr) {
        worker_thread_handles.push_back(h_thread);
    }
}

// 应用退出流程：
processQueue.stop(); // 通知所有线程停止

// 等待所有线程完全退出
WaitForMultipleObjects(
    worker_thread_handles.size(),
    worker_thread_handles.data(),
    TRUE, // 等待所有线程
    INFINITE
);

// 关闭线程句柄，释放系统资源
for (HANDLE h : worker_thread_handles) {
    CloseHandle(h);
}

// 此时再让全局队列processQueue析构（如果是全局变量，会在main退出后自动析构，此时已经没有线程访问它了）

为什么这个方案能解决崩溃？

避免CRT资源销毁顺序冲突：我们主动控制线程在CRT开始销毁前就全部退出，队列的析构不会再触发条件变量的危险操作，或者此时已经没有线程等待，不会访问失效的CRT调度器资源。
线程安全的停止机制：原子停止标志+条件变量唤醒，确保所有线程都能及时收到退出信号，不会卡在无限等待中。
正确的线程终止方式：由线程自身调用_endthreadex，符合CRT的线程管理规范，不会导致资源泄漏或状态混乱。

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