将线程锁定很长时间

编辑2：要澄清的是，我的问题是，我很难写代码来阻止和恢复线程来做一些工作(在这种情况下，读取一些文件)。

编辑3：添加了void Loader:：RequestToLoadRegion(Region&Region)的函数定义。

我想在我的游戏中创建一个基本的流媒体系统。我需要一个线程来读取游戏文件，这些文件大部分时间都会被屏蔽，并不时唤醒。以下是我目前的设计方法。

每当玩家接近未加载在RAM中的世界区域时，游戏向(唯一的)Loader对象发送加载该区域的请求(Loader类表示流系统)。每个区域都有一个与之相关的文件列表，这些文件将被读取以创建游戏数据并加载到RAM中。

加载分两步完成：

• 步骤1：读取所有文件并将其内容推送到队列中
• 步骤2：处理存储在此队列中的原始文件数据

Loader对象使用Reader对象读取所有文件并将其内容推送到上述队列中。在Loader的构造函数中，将构造Reader对象，该对象将启动一个用于读取文件的线程。然而，这个读取线程大部分时间都会被阻塞，并且只有当Loader收到加载新区域的请求时才会被Loader唤醒。

在每帧开始时，Loader将得到控制并检查其当前状态，无论是否加载。如果它处于加载状态，那么它将尝试访问受互斥锁保护的队列。如果它从队列中获得一个项目，它将对其进行处理，并将控制权交还给游戏。队列中的下一个项目将在下一帧上进行处理，依此类推，直到区域加载完成。

我知道如何使用互斥实现这一部分。然而，我遇到了一些麻烦，要阻止读取线程，并在加载请求到达时唤醒它。我已经学会了如何将std:：condition_variable用于基本程序，我目前的解决方案如下：

• 在创建Loader时，它会锁定一个互斥对象，以便读取线程保持阻塞状态
• 当游戏向Loader发送请求时，Loader会将Reader的标志(m_canRead)设置为true，并使用条件变量调用notify_one()来唤醒读取线程

• 当读取线程要读取文件时，它会调用m_loader.OnStartReading()，以便loader锁定m_canReadMutex互斥对象。然后控制权回到读取文件的读取器。

  我在这个设计中遇到的最大问题是，我了解到，通常会在短时间内锁定互斥体，并且通常会将其与std:：lock_guard一起使用，这样，如果发生异常，互斥体就会被解锁。

// This is the function ran by the reading thread
// m_readingThread = std::thread(&Reader::Run, this);
void Reader::Run() {
while (true) {
{
std::unique_lock<std::mutex> ul(m_canReadMutex);
m_canReadCondVar.wait(ul, [this](){ return m_quit || m_canRead; });
// Determine the cause of the wake up
if (m_quit) { // Does the game wants to quit? We break out of
break;      // the loop to reach the end of the Run() function
}             // that way we can join() the reading thread.
// If control reaches this line, it means the thread was awaken by
// a load request and can read. The closing bracket "will run the destructtor"
// of the std::unique_lock to unlock the mutex.
}
{ // When control reaches this scope, it means m_canRead is true.
m_loader.OnStartReading(); // will lock the mutex m_canReadMutex
ReadFiles();
}
}// end-while (true)
}// end-function void Run()
void Reader::ReadFiles() {
/* Read all the files and push data into the queue */
}
void Loader::OnStartReading() {
m_canReadMutex.lock();
}
// This function unlocks the mutex and wake up the reading thread.
void Loader::RequestToLoadRegion(Region &region) {
/* Get the list of files associated to the region */
m_canReadMutex.unlock();
m_reader.m_canRead = true; // Set the flag so the predicate in the reader's wait() evaluates to true
m_canReadCondVar.notify_one(); // Wake up the reader thread
}