使用qt 串口消息队列，有两个一个发数据一个收数据

在Qt中，如果你想通过消息队列来管理串口的发送和接收，可以利用QQueue、信号槽机制以及QMetaObject来实现。下面是一个简化的例子，展示了如何创建两个独立的线程分别负责发送和接收数据：

1. **发送数据线程** (`SendDataThread`)：
这个线程会有一个缓冲区存储待发送的数据，当数据准备好时，放入消息队列。

class SendDataThread : public QThread
{
public:
    SendDataThread(Queue& queue, QObject* parent = nullptr)
        : QThread(parent), m_queue(queue), m_running(false) {}

    ~SendDataThread()
    {
        stop();
    }

private:
    void run() override
    {
        m_running = true;

        while (m_running && !m_queue.isEmpty())
        {
            QByteArray data = m_queue.dequeue(); // 从队列获取数据
            sendData(data);
        }

        qInfo("Send data thread stopped.");
    }

private:
    void sendData(const QByteArray& data)
    {
        // 在这里模拟串口发送，实际使用时替换为QSerialPort的操作
        emit sendDataSignal(data);
    }

signals:
    void sendDataSignal(const QByteArray& data);

private:
    Queue& m_queue;
    bool m_running;
};

2. **接收数据线程** (`ReceiveDataThread`)：
这个线程监听串口的读取事件，一旦有新的数据可用，就将其放入另一个消息队列。

class ReceiveDataThread : public QThread
{
public:
    explicit ReceiveDataThread(QSerialPort& serialPort, QObject* parent = nullptr)
        : QThread(parent), m_serialPort(serialPort), m_dataQueue() {}

    ~ReceiveDataThread()
    {
        stop();
    }

private:
    void run() override
    {
        m_dataQueue.enqueue(m_serialPort.readAll()); // 接收数据并加入到队列

        // ... 实现接收数据的处理逻辑 ...

        qInfo("Receive data thread stopped.");
    }

private:
    QQueue<QByteArray> m_dataQueue;
    QSerialPort& m_serialPort;
};

3. **主线程**：
主线程负责启动和控制这两个线程，并处理它们之间的通信。

void main()
{
    // 创建和配置串口
    QSerialPort serialPort("COM1", 9600);

    // 创建消息队列
    Queue sendQueue;  // 发送数据的队列
    Queue receiveQueue;  // 接收数据的队列

    // 创建并启动发送线程
    SendDataThread sendDataThread(sendQueue);
    connect(&sendDataThread, &SendDataThread::sendDataSignal, &receiveQueue, &Queue::enqueue);

    // 创建并启动接收线程
    ReceiveDataThread receiveDataThread(serialPort);
    connect(&receiveDataThread, &ReceiveDataThread::dataReady, &sendDataThread, &SendDataThread::stopAfterCurrentSend);

    // 开始线程
    sendDataThread.start();
    receiveDataThread.start();

    // 等待线程结束
    sendDataThread.wait();
    receiveDataThread.wait();
}

在这个例子中，`sendDataSignal`信号会在数据准备好的时候发出，`dataReady`信号则表示有新数据到达，这时`SendDataThread`会停止当前的发送并等待下一轮数据。`Queue`类是一个自定义的简单队列，你可以根据需要扩展它。