Qt串口回路信号读取多线程14串口测试方案

QSerialPort串口

一、思路

串口测试分为三种：oT128资讯网——每日最新资讯28at.com

• 回路测试
• 对传
• 485模式，可以传输更远的距离

二、环境

• Qt 6.4.3
• Qt serial port模块
• Qt Creator 11.0.1

三、添加QSerialPort

• 打开Qt mataintenanceTool
• 登录
• 添加/移动组件，点击下一步

oT128资讯网——每日最新资讯28at.com

• 主要是选择Qt Serial Bus, Qt Serial Port
• 点击下一步
• 点击更新即可

四、语句介绍

1.数据控制流

数据控制流 USART_HardwareFlowControl ,控制流，这里的流指数据流，在数据传输中，流控制室管理两个节点之间数据传输速率过程，以防止出现接收端的数据缓存区已满，而发送端依然继续发送数据，所以导致数据丢失。oT128资讯网——每日最新资讯28at.com

(1) 工作原理oT128资讯网——每日最新资讯28at.com

当接受端的数据缓冲区已满，无法处理数据来时，就发出不再接受的信号，发送端则停止发送，直到发送端收到可以继续发送的信号再发送数据，常见的硬件控制流和软件控制流oT128资讯网——每日最新资讯28at.com

(2) 硬件控制流oT128资讯网——每日最新资讯28at.com

oT128资讯网——每日最新资讯28at.com

硬件控制流oT128资讯网——每日最新资讯28at.com

RTS和CTS原本是用来询问和回答是否可以传输数据。在上面的连接上，就是告诉对方自己子否可以进行通讯，此时RTS和DTR都可以用来对数据流进行控制。oT128资讯网——每日最新资讯28at.com

A端DTR(数据设备就绪)发出信号，当B端准备好后，B端的DTR(数据设备就绪)向A端的DSR(通讯设备就绪发送信号)，然后就可以通过RTS(请求发送)和DTR(允许发送)来控制通信。oT128资讯网——每日最新资讯28at.com

硬件控制流并不是单纯依赖硬件，它仍然需要软件去处理识别，硬件控制流所做的只是给出信号电平。oT128资讯网——每日最新资讯28at.com

(3) 软件控制流oT128资讯网——每日最新资讯28at.com

软件流控制(Software flow control)是在计算机数据链路中的一种控制方法，特别适合于RS-232串口通信；它是采用特殊字符来船速带内信令，特殊编码字符称作XOFF与XON(分别表示transmit off与transmit on)。因此也被称作XON/XOFF流控制oT128资讯网——每日最新资讯28at.com

使用ASCII字符集，XOFF一般为字节值19(十进制)，XON为字节值17oT128资讯网——每日最新资讯28at.com

(4) 工作方式oT128资讯网——每日最新资讯28at.com

注意：是接收方把XON/XOFF信号发给发送方来控制发送方何时发送数据，这些信号是与发送数据的传输方向相反的。oT128资讯网——每日最新资讯28at.com

接收方利用XON信号告诉发送方，我已经准备好接受更多的数据了，利用XOFF信号告诉发送方停止发送数据，直到接收方发送XON信号告诉发送方我再次准备好了。oT128资讯网——每日最新资讯28at.com

(5) 设置控制流模式oT128资讯网——每日最新资讯28at.com

setFlowControl 函数：oT128资讯网——每日最新资讯28at.com

// setFlowControl对端口控制进行相关设置 无流量控制serial->setFlowControl(QSerialPort::NoFlowControl);

• NoFlowControl：没有控制
• hardware flow control ：硬件流控制 （RTS/CTS,DTR /DSR等)
• Software flow control ：软件流控制 （XON/XOFF)

oT128资讯网——每日最新资讯28at.com

设置控制流oT128资讯网——每日最新资讯28at.com

2.设置端口

设置端口的名称，此名字可以使用短名称或者长系统地址。oT128资讯网——每日最新资讯28at.com

void QSerialPort::setPortName(const QString &name)

3.波特率

输出传输的速率，每秒传输的比特数。oT128资讯网——每日最新资讯28at.com

enum QSerialPort::BaudRate    /// 可以选择的内容为

4.数据位

设置数据位并保存到帧中，如果设置成功，则返回true,否则返回false,并设置一个错误代码，可以通过访问QSerialPort::error属性的值来获取该代码。oT128资讯网——每日最新资讯28at.com

如果在打开端口之前设置了该设置，则实际的串行端口设置将在QSerialPort::open()方法中自动完成，然后端口打开成功。oT128资讯网——每日最新资讯28at.com

bool setDataBits(DataBits dataBits);DataBits dataBits() const;

oT128资讯网——每日最新资讯28at.com

数据位oT128资讯网——每日最新资讯28at.com

5.奇偶校验位

oT128资讯网——每日最新资讯28at.com

奇偶校验位oT128资讯网——每日最新资讯28at.com

bool setParity(Parity parity);Parity parity() const;

6.设置停止位

oT128资讯网——每日最新资讯28at.com

停止位oT128资讯网——每日最新资讯28at.com

bool setStopBits(StopBits stopBits);StopBits stopBits() const;

7.发送方式

Hex 16进制，本质上就是将字节数数组转化为16进制，然后用字符串的形式发送出去。oT128资讯网——每日最新资讯28at.com

五、对于ui参数随数字变化如何设置

int p = 1;foreach(const QSerialPortInfo &info,QSerialPortInfo::availablePorts()){    PortStringList += info.portName();    ui->port->addItem(info.portName());    // 构造对象名    QString objectName = QString("comlist%1").arg(p);    // 查找对象    QLineEdit *comlist = this->findChild<QLineEdit *>(objectName);    if(comlist) {        comlist->setText(info.portName());    }    p++;}

六、字符串截取

QString snap = QString("COM");int com_num = com.remove(snap).toInt();

七、源代码

linux与windows端通用多线程串口，可同时检测14个串口。oT128资讯网——每日最新资讯28at.com

1.Com_Test.pro

QT       += core guiQT       += serialportgreaterThan(QT_MAJOR_VERSION, 4): QT += widgetsCONFIG += c++17# You can make your code fail to compile if it uses deprecated APIs.# In order to do so, uncomment the following line.#DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0x060000    # disables all the APIs deprecated before Qt 6.0.0SOURCES += /    comthread.cpp /    main.cpp /    mainwindow.cppHEADERS += /    comthread.h /    mainwindow.hFORMS += /    mainwindow.ui# Default rules for deployment.qnx: target.path = /tmp/$${TARGET}/binelse: unix:!android: target.path = /opt/$${TARGET}/bin!isEmpty(target.path): INSTALLS += target

2.comthread.h

#ifndef COMTHREAD_H#define COMTHREAD_H#include <QObject>#include <QSerialPort>#include <QSerialPortInfo>#include <QDebug>#include <QThread>class ComThread :public QObject{    Q_OBJECTpublic:    explicit ComThread(QObject *parent = nullptr);    explicit ComThread(QString portname,qint32 rate,qint32 date,qint32 check_num,qint32 stop_num);    explicit ComThread(qint32 rate,qint32 date,qint32 check_num,qint32 stop_num);    explicit ComThread(QString portname);    // 拷贝构造函数    explicit ComThread(const ComThread &other);    ComThread& operator = (const ComThread &other)    {        qDebug()<<"进入拷贝";        if(this != &other)        {            qDebug()<<"进入拷贝赋值";            this->m_com = other.m_com;            this->mSerialPort = other.mSerialPort;            this->m_check_num = other.m_check_num;            this->m_date = other.m_date;            this->m_rate = other.m_rate;            this->m_stop_num = other.m_stop_num;            qDebug()<<"赋值结束";        }        qDebug()<<"返回值";        return *this;    }    ~ ComThread();public slots:    // 接受传入的串口数据    void slot_recv_com(QString portname,qint32 rate,qint32 date,qint32 check_num,qint32 stop_num);    void slot_recv_com_s(qint32 rate,qint32 date,qint32 check_num,qint32 stop_num);    void slot_recv_com_name(QString portname);    // 对应主线程的信号，需要的槽函数    // 1,打开串口槽函数    // 2,关闭串口槽函数    void slot_openPort();    void slot_closePort();    void slot_handlMessage();    void serial_signal();private:    QSerialPort* mSerialPort;    QString m_com;    qint32 m_rate;    qint32 m_date;    qint32 m_check_num;    qint32 m_stop_num;    QByteArray  Receivetext;signals:    // 发送信号    // 发送字节    void already_send_byte(QString com ,qint32 num);    // 发送接受字节    void already_receive_byte(QString com ,qint32 num);    // 发送是否成功    void result(QString com ,qint32 num);  // 0代表失败 1，代表成功    // 发送接受字符串    void already_receive_string(QString com ,QString string);    void send_com_signal(QString com,bool DTRstate,bool DCDstate,bool DSRstate,bool RINGRstate,bool RTSstate,bool CTSstate,bool STDstate,bool SRDstate);};#endif // COMTHREAD_H

3.comthread.cpp

#include "comthread.h"ComThread::ComThread(QObject *parent)    : QObject{parent}{    //    mSerialPort = nullptr;}ComThread::ComThread(QString portname){    m_com = portname;}ComThread::ComThread(const ComThread &other){//    qDebug()<<"进入赋值拷贝";    this->m_com = other.m_com;    this->mSerialPort = other.mSerialPort;    this->m_check_num = other.m_check_num;    this->m_date = other.m_date;    this->m_rate = other.m_rate;    this->m_stop_num = other.m_stop_num;}ComThread::ComThread(QString portname, qint32 rate,qint32 date,qint32 check_num,qint32 stop_num){    m_com = portname;    m_rate = rate;    m_date = date;    m_check_num = check_num;    m_check_num = stop_num;}ComThread::ComThread(qint32 rate, qint32 date, qint32 check_num, qint32 stop_num){    m_rate = rate;    m_date = date;    m_check_num = check_num;    m_check_num = stop_num;}ComThread::~ComThread(){    if(mSerialPort->isOpen())    {        mSerialPort->close();    }    delete mSerialPort;}void ComThread::slot_recv_com(QString portname, qint32 rate, qint32 date, qint32 check_num, qint32 stop_num){    m_com = portname;    m_rate = rate;    m_date = date;    m_check_num = check_num;    m_stop_num = stop_num;}void ComThread::slot_recv_com_s(qint32 rate, qint32 date, qint32 check_num, qint32 stop_num){    m_rate = rate;    m_date = date;    m_check_num = check_num;    m_stop_num = stop_num;}void ComThread::slot_recv_com_name(QString portname){    m_com = portname;}void ComThread::slot_openPort(){    mSerialPort = new QSerialPort();   //  qDebug()<<" "<< m_com<<" "<<m_rate<<" "<<m_date<<" "<<m_check_num<<" "<<m_stop_num;    // 设置串口对应的名称和波特率    mSerialPort->setPortName(m_com);    mSerialPort->setBaudRate(m_rate);    switch(m_date)    {        //设置对应的数据位        case5:mSerialPort->setDataBits(QSerialPort::Data5);break;        case6:mSerialPort->setDataBits(QSerialPort::Data6);break;        case7:mSerialPort->setDataBits(QSerialPort::Data7);break;        case8:mSerialPort->setDataBits(QSerialPort::Data8);break;        // 若刚开始设置为空，端口打开之后再次进行相关的设置        // 若没有选择就不设置，端口打开之后仍可以设置        //default:serial->setDataBits(QSerialPort::UnknownDataBits);    }    switch(m_check_num)    {        case0:mSerialPort->setParity(QSerialPort::NoParity);break;        case1:mSerialPort->setParity(QSerialPort::EvenParity);break;        case2:mSerialPort->setParity(QSerialPort::OddParity);break;        case3:mSerialPort->setParity(QSerialPort::SpaceParity);break;        case4:mSerialPort->setParity(QSerialPort::MarkParity);break;            //default:serial->setParity(QSerialPort::UnknownParity);    }    switch(m_stop_num)    {        case0:mSerialPort->setStopBits(QSerialPort::OneStop);break;        case1:mSerialPort->setStopBits(QSerialPort::OneAndHalfStop);break;        case2:mSerialPort->setStopBits(QSerialPort::TwoStop);break;        //default:serial->setStopBits(QSerialPort::UnknownStopBits);    }    // 关联读取信号与槽函数，处理信息    mSerialPort->setFlowControl(QSerialPort::NoFlowControl);    connect(mSerialPort,&QSerialPort::readyRead,this,&ComThread::slot_handlMessage);    qDebug()<<"ComThread slot_openport ThreadID"<< QThread::currentThreadId();    if(mSerialPort->open(QIODevice::ReadWrite))    {        this->serial_signal();        // 发送数据        for(int i = 0;i<5;i++)        {            QString realbom = QString("RealReal");            QByteArray send = realbom.toUtf8();            // qDebug()<<send<<"Byte大小:"<<send.length();            mSerialPort->write(send);            emit already_send_byte(m_com,send.length());            // QThread::msleep(1000);            mSerialPort->waitForReadyRead(10); // 接受数据        }        // qDebug()<<"发送完毕";        // mSerialPort->waitForReadyRead(100); // 接受数据        this->slot_closePort();    }    else    {        //  qDebug()<<"return false";        // 关闭信号        emit result(m_com,0);    };    if(Receivetext.size() == 0)    {        //完全没有接收到数据        emit result(m_com,0);    }}void ComThread::slot_closePort(){    if(mSerialPort->isOpen())    {        mSerialPort->close();    }}void ComThread::slot_handlMessage(){    qDebug()<<"调用了此信号";    // mSerialPort->waitForBytesWritten(100);    Receivetext = mSerialPort->readAll();    // qDebug()<<"接收:"<<QString::fromUtf8(Receivetext)<<"Byte大小:"<<Receivetext.length();    emit already_receive_byte(m_com,Receivetext.length());    emit already_receive_string(m_com,QString::fromUtf8(Receivetext));    if(Receivetext == QString("RealReal") && Receivetext.length() == 7)    {        emit result(m_com,1);    }    else    {        emit result(m_com,0);    }}void ComThread::serial_signal(){    // 获取相关高低电压值No    // bool NOstate = serial->pinoutSignals()& QSerialPort::NoSignal; // 没有信号    // 数据终端准备好    bool DTRstate = mSerialPort->pinoutSignals()& QSerialPort::DataTerminalReadySignal;    // 载波信号    bool DCDstate = mSerialPort->pinoutSignals()& QSerialPort::DataCarrierDetectSignal;    // 数据准备好    bool DSRstate = mSerialPort->pinoutSignals()& QSerialPort::DataSetReadySignal;    //    bool RINGRstate = mSerialPort->pinoutSignals()& QSerialPort::RingIndicatorSignal;    // 请求发送    bool RTSstate = mSerialPort->pinoutSignals()& QSerialPort::RequestToSendSignal;    // 清除发送    bool CTSstate = mSerialPort->pinoutSignals()& QSerialPort::ClearToSendSignal;    // 发送数据    bool STDstate = mSerialPort->pinoutSignals()& QSerialPort::SecondaryTransmittedDataSignal;    // 接受数据    bool SRDstate = mSerialPort->pinoutSignals()& QSerialPort::SecondaryReceivedDataSignal;    emit send_com_signal(m_com,DTRstate,DCDstate,DSRstate,RINGRstate,RTSstate,CTSstate,STDstate,SRDstate);    /*    if(DTRstate)    {//        ui->DTR->setStyleSheet("background-color:red");        qDebug()<<"DTRstate";    }    if(DCDstate)    {//        ui->DCD->setStyleSheet("background-color:red");        qDebug()<<"DCDstate";    }    if(DSRstate)    {//        ui->DSR->setStyleSheet("background-color:red");        qDebug()<<"DSRstate";    }    if(RINGRstate)    {//        ui->PNG->setStyleSheet("background-color:red");        qDebug()<<"RINGRstate";    }    if(RTSstate)    {//        ui->RTS->setStyleSheet("background-color:red");         qDebug()<<"RTSstate";    }    if(CTSstate)    {//        ui->CTS->setStyleSheet("background-color:red");         qDebug()<<"CTSstate";    }    if(STDstate)    {//        ui->STD->setStyleSheet("background-color:red");         qDebug()<<"STDstate";    }    if(SRDstate)    {//        ui->SRD->setStyleSheet("background-color:red");         qDebug()<<"SRDstate";    }*/}

4.mainwindow.h

#ifndef MAINWINDOW_H#define MAINWINDOW_H#include <QMainWindow>#include "comthread.h"#include <QThread>//#include <QThreadPool>QT_BEGIN_NAMESPACEnamespace Ui { class MainWindow; }QT_END_NAMESPACEclass MainWindow :public QMainWindow{    Q_OBJECTpublic:    MainWindow(QWidget *parent = nullptr);    ~MainWindow();signals:    void sig_recv_com(QString portname, qint32 rate, qint32 date, qint32 check_num, qint32 stop_num);    void sig_recv_com_s(qint32 rate, qint32 date, qint32 check_num, qint32 stop_num);    void sig_recv_com_name(QString portname);    void sig_openPort();    void sig_closePort();public slots:    // 接受子线程传回的数据    void slots_already_send_byte(QString com ,qint32 num);    // 接受字节    void slots_already_receive_byte(QString com ,qint32 num);    // 是否成功    void slots_result(QString com ,qint32 num);  // 0代表失败 1，代表成功    // 接受字符串    void slots_already_receive_string(QString com ,QString string);    // 接受引脚信号    void send_com_signal(QString com,bool DTRstate,bool DCDstate,bool DSRstate,bool RINGRstate,bool RTSstate,bool CTSstate,bool STDstate,bool SRDstate);private slots:    void on_serial_test_clicked();protected:private:    Ui::MainWindow *ui;    QStringList PortStringList; // 串口列表//    QThreadPool *pool = QThreadPool::globalInstance();    ComThread *comthread;//    std::vector<ComThread> comthread;    QThread *mthread;    QString snap;};#endif // MAINWINDOW_H

5.mainwindow.cpp

#include "mainwindow.h"#include "ui_mainwindow.h"MainWindow::MainWindow(QWidget *parent)    : QMainWindow(parent)    , ui(new Ui::MainWindow){    ui->setupUi(this);    //设计循环，将数据放入list列表当中    int p =1;    foreach(const QSerialPortInfo &info,QSerialPortInfo::availablePorts())    {        PortStringList += info.portName();        ui->port->addItem(info.portName());        // 构造对象名        QString objectName = QString("comlist%1").arg(p);        // 查找对象        QLineEdit *comlist = this->findChild<QLineEdit *>(objectName);        if(comlist) {            comlist->setText(info.portName());        }        p++;    }    //设置UI页面的默认Index    ui->bo_num->setCurrentIndex(5);    ui->data_num->setCurrentIndex(3);    ui->check_num->setCurrentIndex(2);    ui->stop_num->setCurrentIndex(0);}MainWindow::~MainWindow(){    delete ui;    if(mthread->isRunning())    {        mthread->quit();        mthread->wait();        delete[] mthread;//        delete[] comthread;    }}void MainWindow::slots_already_send_byte(QString com, int num){    int com_num = com.remove(snap).toInt();    QString objectname = QString("send_byte_") + QString::number(com_num);    QLabel *label = this->findChild<QLabel *>(objectname);    if(label)    {        label->setText(QString::number(num));    }    qDebug()<<com<<"已发送"<<num;}void MainWindow::slots_already_receive_byte(QString com, int num){    int com_num = com.remove(snap).toInt();    QString objectname = QString("recv_byte_") + QString::number(com_num);    QLabel *label = this->findChild<QLabel *>(objectname);    if(label)    {        label->setText(QString::number(num));    }    qDebug()<<com<<"已接收"<<num;}void MainWindow::slots_result(QString com, int num){    int com_num = com.remove(snap).toInt();    QString objectname = QString("list_result_") + QString::number(com_num);    QPushButton *button = this->findChild<QPushButton *>(objectname);    if(button)    {        if(1 == num)        {            button->setText("通过");            button->setStyleSheet("background-color:rgb(27,167,132)");        }        else        {            button->setText("失败");            button->setStyleSheet("background-color:rgb(238, 72, 99)");        }    }    qDebug()<<com<<"测试结果(0代表失败 1，代表成功)"<<num;}void MainWindow::slots_already_receive_string(QString com, QString string){    int com_num = com.remove(snap).toInt();    QString objectname = QString("recv_date_") + QString::number(com_num);    QLineEdit *Edit = this->findChild<QLineEdit *>(objectname);    if(Edit)    {        Edit->setText(string);    }    qDebug()<<com<<"已接收字符串"<<string;}void MainWindow::send_com_signal(QString com, bool DTR, bool DCD, bool DSR, bool RNG, bool RTS, bool CTS, bool STD, bool SRD){    int com_num = com.remove(snap).toInt();    {        if(DTR)        {            QString objectname = QString("DTR_") + QString::number(com_num);            QToolButton *ToolButton = this->findChild<QToolButton *>(objectname);            if(ToolButton)            {                ToolButton->setStyleSheet("background-color:rgb(240, 124, 130)");            }        }        if(DCD)        {            QString objectname = QString("DCD_") + QString::number(com_num);            QToolButton *ToolButton = this->findChild<QToolButton *>(objectname);            if(ToolButton)            {                ToolButton->setStyleSheet("background-color:rgb(240, 124, 130)");            }        }        if(DSR)        {            QString objectname = QString("DSR_") + QString::number(com_num);            QToolButton *ToolButton = this->findChild<QToolButton *>(objectname);            if(ToolButton)            {                ToolButton->setStyleSheet("background-color:rgb(240, 124, 130)");            }        }        if(RNG)        {            QString objectname = QString("RNG_") + QString::number(com_num);            QToolButton *ToolButton = this->findChild<QToolButton *>(objectname);            if(ToolButton)            {                ToolButton->setStyleSheet("background-color:rgb(240, 124, 130)");            }        }        if(RTS)        {            QString objectname = QString("RTS_") + QString::number(com_num);            QToolButton *ToolButton = this->findChild<QToolButton *>(objectname);            if(ToolButton)            {                ToolButton->setStyleSheet("background-color:rgb(240, 124, 130)");            }        }        if(CTS)        {            QString objectname = QString("CTS_") + QString::number(com_num);            QToolButton *ToolButton = this->findChild<QToolButton *>(objectname);            if(ToolButton)            {                ToolButton->setStyleSheet("background-color:rgb(240, 124, 130)");            }        }        if(STD)        {            QString objectname = QString("STD_") + QString::number(com_num);            QToolButton *ToolButton = this->findChild<QToolButton *>(objectname);            if(ToolButton)            {                ToolButton->setStyleSheet("background-color:rgb(240, 124, 130)");            }        }        if(SRD)        {            QString objectname = QString("SRD_") + QString::number(com_num);            QToolButton *ToolButton = this->findChild<QToolButton *>(objectname);            if(ToolButton)            {                ToolButton->setStyleSheet("background-color:rgb(240, 124, 130)");            }        }    }    qDebug()<<"com"<<"DTRstate"<<"DCDstate"<<"DSRstate"<<"RINGRstate"<<"RTSstate"<<"CTSstate"<<"STDstate"<<"SRDstate";    qDebug()<<com<<DTR<<DCD<<DSR<<RNG<<RTS<<CTS<<STD<<SRD;}// 点击进入串口回路测试void MainWindow::on_serial_test_clicked(){    // 判断当前系统#ifdef Q_OS_WIN    snap = QString("COM");#elif defined(Q_OS_LINUX)    snap = QString("ttyS");#endif    int qserial_size = PortStringList.size();    bool open_test[qserial_size];    for (int i = 0; i < qserial_size; ++i) {        open_test[i] = true;    }    // 获取串口等信息    QString Port = ui->port->currentText();    qint32 rate = ui->bo_num->currentText().toInt();    qint32 date = ui->data_num->currentText().toInt();    qint32 check_num = ui->check_num->currentIndex();    qint32 stop_num = ui->stop_num->currentIndex();//    qDebug()<<"检查位:"<<check_num<<"停止位:"<<stop_num;    // TODO多com口同时测试  14个线程    mthread = new QThread[qserial_size];    /*    // comthread = new ComThread(Port,rate,date,check_num,stop_num);    // comthread = new ComThread[14](Port,rate,date,check_num,stop_num);    // ComThread * comthread = new ComThread[PortStringList.size()];//    comthread = new ComThread[qserial_size];    // 为每个元素分配对应的端口，并初始化ComThread对象数组//    for (int i = 0; i < qserial_size; ++i) {//        comthread[i] = ComThread(PortStringList.at(i));//    }*//*    for(int m = 0;m < qserial_size; m++)    {        // comthread[m] = ComThread(PortStringList.at(m));//        comthread.emplace_back(ComThread(PortStringList.at(m)));    }    {        ComThread(PortStringList.at(0)),        ComThread(PortStringList.at(1)),        ComThread(PortStringList.at(2)),        ComThread(PortStringList.at(3)),        ComThread(PortStringList.at(4)),        ComThread(PortStringList.at(5)),        ComThread(PortStringList.at(6)),        ComThread(PortStringList.at(7)),        ComThread(PortStringList.at(8)),        ComThread(PortStringList.at(9)),        ComThread(PortStringList.at(10)),        ComThread(PortStringList.at(11)),        ComThread(PortStringList.at(12)),        ComThread(PortStringList.at(13)),    };*/    int i = 0;    foreach(QString com_e,PortStringList)    {        ComThread *comthread = new ComThread(com_e);        // qDebug()<<com_e;        // 移入线程//        comthread[i].moveToThread(&mthread[i]);        comthread->moveToThread(&mthread[i]);        mthread[i].start();        //关联信号        if(open_test[i])        {//            connect(this,&MainWindow::sig_openPort,&comthread[i],&ComThread::slot_openPort);//            connect(this,&MainWindow::sig_recv_com_s,&comthread[i],&ComThread::slot_recv_com_s);            connect(this,&MainWindow::sig_openPort,comthread,&ComThread::slot_openPort);            connect(this,&MainWindow::sig_recv_com_s,comthread,&ComThread::slot_recv_com_s);            // 关联返回信号            connect(comthread,&ComThread::already_receive_byte,this,&MainWindow::slots_already_receive_byte);            connect(comthread,&ComThread::already_receive_string,this,&MainWindow::slots_already_receive_string);            connect(comthread,&ComThread::already_send_byte,this,&MainWindow::slots_already_send_byte);            connect(comthread,&ComThread::result,this,&MainWindow::slots_result);            connect(comthread,&ComThread::send_com_signal,this,&MainWindow::send_com_signal);            open_test[i] = false;        }        qDebug()<<"main ThreaiD:"<<QThread::currentThreadId();        emit sig_recv_com_s(rate,date,check_num,stop_num);        emit sig_openPort();//        pool->start(comthread);        {            // 取消单个信号对所有串口的信号连接//            disconnect(this,&MainWindow::sig_openPort,&comthread[i],&ComThread::slot_openPort);//            disconnect(this,&MainWindow::sig_recv_com_s,&comthread[i],&ComThread::slot_recv_com_s);            disconnect(this,&MainWindow::sig_openPort,comthread,&ComThread::slot_openPort);            disconnect(this,&MainWindow::sig_recv_com_s,comthread,&ComThread::slot_recv_com_s);        }        i++;        // pool->waitForDone();        //        qDebug()<<"执行结束";//        QThread::sleep(1);        // mthread->quit();        // mthread[0].isFinished();    }    // 循环结束线程    for(int j = 0;j<PortStringList.size();j++)    {        if(mthread[j].isFinished())        {            // qDebug()<<"quit"<<j;            mthread[j].quit();            mthread[j].wait();        }        else        {            // qDebug()<<"wait"<<j;            mthread[j].quit();            mthread[j].wait();        }    }//    delete [] mthread;}

6.main.cpp

#include "mainwindow.h"#include <QApplication>int main(int argc, char *argv[]){    QApplication a(argc, argv);    MainWindow w;    w.show();    return a.exec();}

八、问题解决

1.多线程中出现QObject: Cannot create children for a parent that is in a different thread

这个错误提示的实际意思是，不能在子线程中生成跨线程调用的成员。如果一个成员在父线程中被直接调用了，那么这个成员必须处在父线程中，强行在子线程中生成就会出现这个错误提示。oT128资讯网——每日最新资讯28at.com

将在多线程中构造函数中new出来的变量，放到run中执行，因为构造函数是在主线程完成初始化的，线程所属于不同的线程，就会出现此类错误。oT128资讯网——每日最新资讯28at.com

解决此问题的关键将线程放到一个地方，例如子线程中的对串口的new定义。oT128资讯网——每日最新资讯28at.com

2.munmap_chunk(): invalid pointer解决方案线程池释放，程序崩溃

程序分析：将程序线程池取消自动释放，结果程序确实没有发生崩溃，可以继续运行，所以分析断定，程序崩溃为线程池析构时的问题。oT128资讯网——每日最新资讯28at.com

展示关闭线程自动销毁功能，同时程序中多次使用。oT128资讯网——每日最新资讯28at.com

解决方案：检查程序结束，或者异常结束资源销毁问题。oT128资讯网——每日最新资讯28at.com

3.循环发送信息，并没有收到数据，而是最后一起收到数据

在发送数据之后，加入waitForReadyRead(10);函数，就会接受数据，此函数功能为等待接受，与其说等待，其实立马就接受了数据。否则在测试当中出现了五次循环结束，一同接受数据的情况。oT128资讯网——每日最新资讯28at.com

for(int i = 0;i<5;i++){    QString realbom = "realbom";    QByteArray send = realbom.toUtf8();    qDebug()<<send;    mSerialPort->write(send);//        QThread::sleep(1);    mSerialPort->waitForReadyRead(10); // 接受数据}

4.接受数据和发送数据格式不同，接受数据乱码

• 查询是否是串口参数配置问题。我的确实是此问题，当时确实是玩完没有想到，设置默认值之后，就可以
• 设置正确的编码转换关系

QByteArray send = realbom.toUtf8();qDebug()<<send<<"Byte大小:"<<send.length();mSerialPort->write(send);QByteArray  Receivetext = mSerialPort->readAll();qDebug()<<"接收:"<<QString::fromUtf8(Receivetext)<<"Byte大小:"<<Receivetext.length();

oT128资讯网——每日最新资讯28at.com

本文链接：http://www.28at.com/showinfo-26-25979-0.htmlQt串口回路信号读取多线程14串口测试方案

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com

上一篇： Java下跌，被C#逼近！Kotlin后生可畏

下一篇： 应用获取客户端真实IP