如何实现消费者可以请求新数据的消费者生产者？

Question

嘿。

我甚至不确定这个问题的题目该怎么写。

生产者:我有一个案例，我想在屏幕上显示一些数据，但每次用户与window交互时，它们都需要重新计算。对于单击、拖动或滚轮事件，我发送请求重新计算的信号。因此，对于旋转(拖动事件)，可能会发出数十个请求。但是，如果数据已经在重新计算，则进程必须停止并重新启动。重新计算可能需要10毫秒到5秒。然后使用信号量/互斥锁，当数据准备就绪时，在鼠标悬停事件下显示一些信息。

消费者:应收到重算请求并开始重算。也应该停止之前的任何计算。当计算结束时，解锁互斥锁/信号量。

我一直在思考和搜索，但仍然无法找到一个完美的解决方案。你能给我指出一些在这种情况下可以工作的一般解决方案吗？

关于QT的信号和插槽系统的一些事实，我认为与这个问题相关：-当执行计算时，eventloop是不活动的，因此插槽直到计算完成才会执行-插槽一次执行一个

我的解决方案是在主线程中使用Consumer，在自己的线程中使用Worker和Superviser。但希望你能帮我找到更好/更干净的解决方案。

Mitja

Answer 1

一种方法是将计算分块并在计时器事件中进行处理：

因此，如果您当前的算法看起来像

void MyObject::calculate()
{
    // data and state
    while(processing)
    {
        ///do some chunk of work
    }
    emit done(result);
}

它将会成为

// data and state in fields

void MyObject::calculate()
{
    if(!timerId)
        timerId = startTimer(0);//timeout of 0 means 

    //reset state and set data
}

void MyObject::timerEvent(QTimerEvent* event)
{
    ///do some chunk of work

    if(done)
    {
        emit done(result);
        killTimer(timerId);
        timerId = 0;
    {
}

不需要信号量，因为它们都发生在同一个事件循环中。您甚至不需要单独的线程，因为事件循环可以保持运行。