c多线程串口通信收发

实现串口通信的多线程程序可以分为两个部分：串口通信线程和数据处理线程。

首先，我们需要创建一个串口通信类，并在其中创建一个线程来负责串口数据的发送和接收。该线程一般是一个死循环，不断地从串口读取数据，并根据数据的类型进行不同的处理。同时，该线程也需要负责将数据发送到串口。

其次，我们需要创建一个数据处理线程，来处理从串口接收到的数据。该线程一般是一个消息队列，用于接收串口线程发送过来的数据，并进行相应的处理。这里的处理可以是对数据进行解析或者存储等操作。

下面是一个基本的多线程串口通信收发的示例代码：

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <queue>
#include <chrono>
#include <cstring>
#include "SerialPort.h"

using namespace std;

class SerialThread {
public:
    SerialThread(string portName, int baudRate) : m_port(portName, baudRate) {}
    ~SerialThread() {}

    void start() {
        m_thread = thread([this](){ this->run(); });
    }

    void stop() {
        m_running = false;
        m_thread.join();
    }

    void send(const string& data) {
        lock_guard<mutex> lock(m_mutex);
        m_writeQueue.push(data);
        m_cv.notify_one();
    }

    string receive() {
        lock_guard<mutex> lock(m_mutex);
        if (m_readQueue.empty()) {
            return "";
        }
        string data = m_readQueue.front();
        m_readQueue.pop();
        return data;
    }

private:
    void run() {
        m_running = true;
        while (m_running) {
            // 读取串口数据
            string data = m_port.read();
            if (!data.empty()) {
                // 将数据添加到读队列中
                lock_guard<mutex> lock(m_mutex);
                m_readQueue.push(data);
            }

            // 发送串口数据
            string writeData;
            {
                unique_lock<mutex> lock(m_mutex);
                m_cv.wait_for(lock, chrono::milliseconds(10), [this](){ return !m_writeQueue.empty(); });
                if (!m_writeQueue.empty()) {
                    writeData = m_writeQueue.front();
                    m_writeQueue.pop();
                }
            }
            if (!writeData.empty()) {
                m_port.write(writeData);
            }
        }
    }

private:
    SerialPort m_port;
    thread m_thread;
    bool m_running;

    queue<string> m_readQueue;
    queue<string> m_writeQueue;
    mutex m_mutex;
    condition_variable m_cv;
};

int main() {
    SerialThread serial("COM1", 9600);
    serial.start();

    // 发送数据
    serial.send("Hello, world!");

    // 接收数据
    string data = serial.receive();
    if (!data.empty()) {
        cout << "Received data: " << data << endl;
    }

    serial.stop();
    return 0;
}

在上面的示例代码中，我们创建了一个SerialThread类来实现串口通信的多线程程序。该类中包含了一个串口对象和读、写消息队列。串口线程不断地从串口读取数据，并将其添加到读队列中；同时，也会从写队列中取出数据并发送到串口。主线程可以调用SerialThread的send和receive方法来发送和接收数据。