c++ - 多线程输入处理

Question

我是使用多线程的新手，我正在开发一个处理鼠标移动的程序，它由两个线程组成，主线程获取输入并将鼠标位置存储在固定位置，子线程循环遍历该位置获得值(value)。那么如何降低 CPU 利用率，我正在使用条件变量来实现这一点，有没有更好的方法来做到这一点？看来给子线程加个延迟也行

void Engine::InputManager::MouseMove(const MouseMoveEvent& ev)
{
    cur_mouse_ev_.x_ = ev.x_;
    cur_mouse_ev_.y_ = ev.y_;
    cv_.notify_all();
}
void Engine::InputManager::ProcessInput(MouseMoveEvent* ev)
{
    while (true)
    {
        cv_.wait(u_mutex_);
        float dx = static_cast<float>(ev->x_ - pre_mouse_pos[0]) * 0.25f;
        float dy = static_cast<float>(ev->y_ - pre_mouse_pos[1]) * 0.25f;
        g_pGraphicsManager->CameraRotateYaw(dx);
        pre_mouse_pos[0] = ev->x_;
        pre_mouse_pos[1] = ev->y_;
    }
}

Answer 1

使用 std::condition_variable 是实现您想要的效果的好方法。

但是 - 您的实现存在以下问题:std::condition_variable 遭受虚假唤醒。您可以在这里阅读:Spurious wakeup - Wikipedia .

使用条件变量的正确方法需要:

1. 添加一个变量(在您的情况下为 bool)来保存您正在等待的“条件”。应使用互斥锁在锁下更新变量。

2. 再次锁定:在循环中调用 wait 直到变量满足您正在等待的条件。如果发生虚假唤醒，循环将确保再次进入等待状态。顺便说一句 - wait 方法有一个重载，它获取条件的谓词，并为您循环。

您可以在此处查看一些代码示例: Condition variable examples .

演示流程的最小示例:

#include <thread>
#include <mutex>
#include <condition_variable>

std::mutex              mtx;
std::condition_variable cond_var;
bool                    ready{ false };

void handler()
{
    {
        std::unique_lock<std::mutex> lck(mtx);
        cond_var.wait(lck, []() { return ready; }); // will loop internally to handle spurious wakeups
    }
    // Handle data ...
}

void main()
{
    std::thread t(handler);

    // Prepare data ...
    std::this_thread::sleep_for(std::chrono::seconds(3));

    {
        std::unique_lock<std::mutex> lck(mtx);
        ready = true;
    }
    cond_var.notify_all();
    t.join();
}