QT多线程和自定义信号

利用多线程实现并发服务器

1. 创建线程类myThread，继承于QThread（本身也继承于QObject）
2. myThread定义里要加上Q_OBJECT的宏，不然没法使用信号和槽
3. 重写run()线程处理函数
4. 创建线程对象，调用start()函数启动线程

myThread.cpp

#include "mythread.h"myThread::myThread(QTcpSocket*s)
{socket=s;
}void myThread::run()
{
//    connect(socket,&QTcpSocket::readyRead,this,&myThread::clientInfoSLot);connect(socket,SIGNAL(readyRead()),this,SLOT(clientInfoSLot()));}
void myThread::clientInfoSLot()
{QString Buf;Buf=socket->readAll();qDebug()<<Buf; //ui界面只能在自己的类里操作
}

myThread.h

#ifndef MYTHREAD_H
#define MYTHREAD_H#include <QObject>
#include <QThread>
#include <QTcpSocket>
#include <QDebug>
class myThread :public QThread
{Q_OBJECT//加上这个宏才能使用信号和槽
public:explicit myThread(QTcpSocket*s);//构造函数void run(); //重写run，线程处理函数private:QTcpSocket* socket;public slots:void clientInfoSLot();
signals:};#endif // MYTHREAD_H

这里有个问题就是线程里接收到的数据无法直接显示到ui界面，因此使用了qDebug。
使用自定义信号可以解决这个问题

自定义信号

信息流转流程：线程里收到数据后，通过emit发出信号，同时信号中携带数据变量Buf，发出的信号导致执行槽函数，槽函数接收信号中的变量并处理

myThread.h

#include <QObject>
#include <QThread>
#include <QTcpSocket>
#include <QDebug>
class myThread :public QThread
{Q_OBJECT//加上这个宏才能使用信号和槽
public:explicit myThread(QTcpSocket*s);//构造函数void run(); //重写run，线程处理函数private:QTcpSocket* socket;public slots:void clientInfoSLot();
signals:void sendToWidget(QString Buf);//声明信号
};#endif // MYTHREAD_H

myThread.cpp

#include "mythread.h"myThread::myThread(QTcpSocket*s)
{socket=s;
}void myThread::run()
{
//    connect(socket,&QTcpSocket::readyRead,this,&myThread::clientInfoSLot);connect(socket,SIGNAL(readyRead()),this,SLOT(clientInfoSLot()));}
void myThread::clientInfoSLot()
{QString Buf;Buf=socket->readAll();
//    qDebug()<<Buf;//ui界面只能在ui类里操作emit sendToWidget(Buf);//发出信号
}

在widget.cpp里连接信号sendToWidget(Buf)和槽函数threadSlot(QString Buf)
同时在widget.h声明槽函数void threadSlot(QString Buf);，槽函数的具体功能就是实现数据的ui显示

widget.cpp

//连接、接收数据
void Widget::newConnection_SLOT()
{QMessageBox::information(this,"连接","成功");tcpScoket=tcpServer->nextPendingConnection();
//    connect(tcpScoket,SIGNAL(readyRead()),this,SLOT(readyRead_SLOT()));//启动线程myThread*t=new myThread(tcpScoket);//创建线程对象t->start();//开始线程connect(t,&myThread::sendToWidget,this,&Widget::threadSlot); //线程发出的信号
}void Widget::threadSlot(QString Buf)
{ui->receiveEdit->appendPlainText(Buf);
}