在条件变量等待时关闭时如何阻止 C++ 程序崩溃？

Question

我正在为我的项目构建一个多线程服务器。
我正在使用条件变量和锁。
我将条件变量 cv 作为全局变量，将互斥体 _mtxReceivedMessages 作为类成员。

这是等待用户消息的函数：

void Server::handleReceivedMessages()
{
 while (1)
 {
    std::unique_lock<std::mutex> lck(_mtxReceivedMessages);
    while (_queRcvMessages.size() == 0) cv.wait(lck); // As long as there are 0 messages in the queue
 }
}

这是调用通知 cv 的函数：

void Server::addReceivedMessage(ReceivedMessage* msg)
{
    _queRcvMessages.push(msg); // Adds the message to the queue
    cv.notify_all(); // Unlockes all locked functions
}

问题是，如果我在函数 handleReceivedMessages 等待时（在调用函数 addReceivedMessage 之前）尝试关闭程序，程序会崩溃，
但如果我删除该行：

 while (_queRcvMessages.size() == 0) cv.wait(lck); // As long as there are 0 messages in the queue

程序退出就好了。

程序崩溃：Nuvola.exe 中 0x7748507C (ntdll.dll) 处出现未处理异常：0xC000000D：向服务或函数传递了无效参数。

可能是什么问题？

Answer 1

如果你想要干净的关机，你需要把它设计成一切。您的服务器需要一个关闭函数（可以是它的析构函数）。而且您的handleReceivedMessages 函数需要一种在关机时停止的方法。

例如，您可以将bool shutdown; 添加到您的Server 类中。要关闭类，请获取互斥体，将shutdown 设置为true，然后向条件变量发出信号。 （如果有的话，你可能需要join服务器的线程。）

你的handleReceivedMessages 函数看起来更像这样：

void Server::handleReceivedMessages()
{
 while (1)
 {
    std::unique_lock<std::mutex> lck(_mtxReceivedMessages);
    while (!shutdown && _queRcvMessages.size() == 0) cv.wait(lck); // As long as there are 0 messages in the queue
    if (shutdown) return;
 }
}