Qt使用消息队列传递数据

在Qt中使用消息队列（也称为事件队列）传递数据非常常见，特别是在多线程编程中。下面是一个简单的示例，展示如何在两个线程之间使用消息队列传递数据：

#include <QCoreApplication>
#include <QThread>
#include <QEvent>
#include <QEventLoop>
#include <QDebug>

// 自定义事件类型，用于传递数据
class MyEvent : public QEvent
{
public:
    static const QEvent::Type EventType;

    MyEvent(int value) : QEvent(EventType), m_value(value) {}

    int value() const { return m_value; }

private:
    int m_value;
};

const QEvent::Type MyEvent::EventType = static_cast<QEvent::Type>(QEvent::registerEventType());

// 生产者线程
class ProducerThread : public QThread
{
public:
    void run() override {
        for (int i = 0; i < 10; ++i) {
            QCoreApplication::postEvent(qApp, new MyEvent(i));
            msleep(1000); // 模拟耗时操作
        }
    }
};

// 消费者对象
class ConsumerObject : public QObject
{
public:
    ConsumerObject() {
        moveToThread(&m_thread);
        m_thread.start();
    }

    ~ConsumerObject() {
        m_thread.quit();
        m_thread.wait();
    }

    // 事件处理函数，处理自定义事件类型
    bool event(QEvent *event) override {
        if (event->type() == MyEvent::EventType) {
            MyEvent *myEvent = static_cast<MyEvent*>(event);
            qDebug() << "Received value:" << myEvent->value() << "on thread:" << QThread::currentThread();
            return true;
        }
        return QObject::event(event);
    }

private:
    QThread m_thread;
};

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    // 创建生产者线程
    ProducerThread producer;
    producer.start();

    // 创建消费者对象
    ConsumerObject consumer;

    return a.exec();
}

在上面的示例中，我们创建了一个自定义事件类型`MyEvent`，用于传递数据。生产者线程`ProducerThread`向消息队列中发送事件，而消费者对象`ConsumerObject`则在其自己的线程中，通过重载`event()`函数处理这些事件。当一个`MyEvent`事件被消费者对象接收时，它会打印出事件的值，并指出当前所在线程。

需要注意的是，在Qt中发送事件需要使用`QCoreApplication::postEvent()`函数，该函数可以将事件添加到应用程序的事件队列中。在消费者对象中，我们必须将它移动到一个新线程中，并在该线程中启动事件循环，以便可以接收事件。

此外，请注意，如果您使用Qt的信号和槽机制来传递数据，则不需要使用消息队列。消息队列通常用于在多个线程之间传递数据，而信号和槽机制则可在同一线程内传递数据。