Qt槽函数：解决收发线程速率差异，避免调用请求排队

这个问题我刚好之前处理过——Qt的事件队列默认会把所有Qt::QueuedConnection类型的调用都排队执行，当数据生成线程比UI线程快时，旧的无效请求会堆积，拖慢整个程序。下面给你两个实用的解决方案，按需选择：

方案一：用原子标志位过滤重复请求 #

如果你的newData槽不需要直接传递数据（比如数据已经存在线程安全的共享容器里），这个方法最简单直接。核心思路是：用一个原子变量跟踪是否已有未处理的请求，只有当没有pending请求时，才发起新的invokeMethod调用。

步骤1：在Processor类中添加原子标志位 #

#include <atomic>
#include <QObject>

class Processor : public QObject
{
    Q_OBJECT
private:
    // 原子标志位，标记是否有未处理的newData请求
    std::atomic<bool> m_hasPendingRequest{false};

public slots:
    void newData() {
        // 这里处理你的数据显示逻辑
        // ...

        // 处理完成后，重置标志位
        m_hasPendingRequest.store(false, std::memory_order_release);
    }
};

步骤2：在数据生成线程中发起调用前检查标志位 #

// 生成数据的线程代码
if (!processor->m_hasPendingRequest.exchange(true, std::memory_order_acq_rel)) {
    // 只有当之前没有pending请求时，才发起调用
    QMetaObject::invokeMethod(processor, "newData", Qt::QueuedConnection);
}

这里的exchange是原子操作：它会把标志位设为true，同时返回原来的值。如果原来的值是false，说明当前没有排队的请求，就执行invokeMethod；如果是true，直接跳过这次调用，避免重复排队。

方案二：自定义事件替换旧请求（适合需要传递数据的场景） #

如果你的newData需要随调用传递数据（比如每次生成的数据都要传给UI），自定义事件的方式更合适——它可以直接替换事件队列里的旧请求，让UI只处理最新的数据。

步骤1：自定义数据事件类 #

#include <QEvent>
#include <YourDataType.h> // 替换成你的数据类型

class NewDataEvent : public QEvent
{
public:
    // 自定义事件类型，用QEvent::User之后的数值避免冲突
    static const QEvent::Type EventType = static_cast<QEvent::Type>(QEvent::User + 1);

    explicit NewDataEvent(const YourDataType& data)
        : QEvent(EventType), m_data(data) {}

    YourDataType m_data; // 存储要传递的数据
};

步骤2：修改Processor类处理自定义事件 #

#include <QCoreApplication>
#include <atomic>

class Processor : public QObject
{
    Q_OBJECT
private:
    // 跟踪当前pending的事件，原子操作保证线程安全
    std::atomic<NewDataEvent*> m_currentPendingEvent{nullptr};

    // 实际处理数据的函数
    void processData(const YourDataType& data) {
        // 这里写你的显示逻辑
        // ...
    }

protected:
    bool event(QEvent* event) override {
        if (event->type() == NewDataEvent::EventType) {
            NewDataEvent* newDataEvent = static_cast<NewDataEvent*>(event);
            // 处理最新的数据
            processData(newDataEvent->m_data);
            // 重置pending事件指针
            m_currentPendingEvent.store(nullptr);
            return true;
        }
        return QObject::event(event);
    }
};

步骤3：在数据生成线程中发送事件 #

// 生成数据的线程代码
YourDataType latestData = generateYourData(); // 生成最新数据
NewDataEvent* newEvent = new NewDataEvent(latestData);

// 原子替换当前pending的事件
NewDataEvent* oldEvent = processor->m_currentPendingEvent.exchange(newEvent);
if (oldEvent) {
    // 如果有旧的pending事件，从事件队列移除并销毁，避免处理旧数据
    QCoreApplication::removePostedEvent(processor, oldEvent);
    delete oldEvent;
}

// 发送新事件到UI线程队列
QCoreApplication::postEvent(processor, newEvent);

这个方案会自动丢弃旧的未处理事件，只让UI处理最新的数据，完美解决旧数据无效的问题。

注意事项 #

• 所有跨线程访问的变量必须用原子类型（比如std::atomic）或者加互斥锁，避免线程竞争问题。
• 不要用Qt::DirectConnection，否则槽函数会在数据生成线程执行，UI操作非线程安全，容易崩溃。

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