Qt中moveToThread注意的地方

????????Qt中的QObject对象默认是在主线程创建的。当使用moveToThread方法将对象移动到其他线程后,对象的构造函数仍然是在主线程执行的。moveToThread方法仅仅是让对象的事件循环、信号槽连接等引用主线程的资源移动到目标线程,但对象本身是不会移动的。

例如:

class Work : public QObject 
{
  Q_OBJECT

  public:
    Work()         //work的构造函数
    {
        qDebug() << "构造函数的线程ID:" << QThread::currentThread(); 
    }
};

// 在主线程
Work *work = new Work;
work->moveToThread(workerThread); 

// 输出为:
// 构造函数的线程ID: 0xMAIN_THREAD_ID   ,是主线程的id

这里Work对象是在主线程使用new关键字构造的,所以它的构造函数也在主线程执行。

即使使用了moveToThread方法移动到工作线程,对象本身依然保持不动,只是相关资源如事件循环移动到工作线程。

所以总结来说:

• QObject对象的构造函数总是在 new该对象的线程里执行
• moveToThread只是移动相关资源,对象本身不移动
• 对象创建与移动到其他线程是两个独立的操作

使用moveToThread需要注意的几个问题：

问题1.将要移入线程中的那个类应该使用 new 来创建，不能使用写成了局部对象的方式，从而会导致槽函数无法触发。

QThread *thread = new QThread(this);
**//此处是局部变量，一旦跑出这个局部函数，read将不存在，自然就不能触发槽函数**
QReadMsg read(tcpClient) ;//业务处理对象
read->moveToThread(&thread);

正确方式：

QThread *thread = new QThread(this);
//此处使用new，放在堆中，read除非手动释放，否则一直存在，记得线程结束时候手动释放
QReadMsg *read = new QReadMsg();//业务处理对象
read->moveToThread(thread);

问题2.子线程中进行业务处理，将结果放在信号中发送给父线程触发父线程的槽函数。如果信号触发过快，会导致槽函数无法触发。

解决办法：在信号发送的地方延时一点时间，让槽函数能够有时间触发。或者增加一个QApplication::processEvents();

QThread *thread = new QThread(this);
//此处使用new，放在堆中，read除非手动释放，否则一直存在，记得线程结束时候手动释放
QReadMsg *read = new QReadMsg(tcpClient);
read->moveToThread(thread);//业务处理对象
connect(tcpClient, &QTcpSocket::readyRead,read,&QReadMsg::slot_ReadData);
//子线程的带参信号连接父线程的槽函数
connect(read, &QReadMsg ::displayRecvData,this,[=](QString str ){
	ui->linetest.setText(str );
});
thread->start();
emit readyRead();

子进程

方法一：

while(1)
{
	//读取数据
	emit displayRecvData();//触发信号
	//增加延迟函数
	QThread::sleep(2);
}

方法二：

while(1)
{
	//读取数据
	emit displayRecvData();//触发信号
	//用于处理当前事件队列中的所有事件，它会依次处理每个事件，直到队列为空或者遇到了个退出事件。\
    在 GUI应用程序中，通常需要在主循环中调用这个函数，以确保界面能够及时响应用户的操作。
	QApplication::processEvents();
}

问题3.moveToThread以后，界面还是假死，子线程ID和主线程ID相同，没有在新线程中处理业务。

错误写法：

QThread *thread = new QThread(this);
//此处使用new，放在堆中，read除非手动释放，否则一直存在，记得线程结束时候手动释放
QReadMsg *read = new QReadMsg(this);    //业务处理对象
read->moveToThread(thread);

注意QReadMsg *read = new QReadMsg(this)，这个地方不能传入this。
如果传入this，业务就被托管this的线程中了，即还是在主线程。

正确写法：

QThread *thread = new QThread(this);
//此处使用new，放在堆中，read除非手动释放，否则一直存在，记得线程结束时候手动释放
QReadMsg *read = new QReadMsg;//业务处理对象
read->moveToThread(thread);

问题4.在把work类对象moveToThread后，需要在内部使用QTimer来执行处理部分操作，但是QTimer的槽函数不响应。(Qt中的QObject对象默认是在主线程创建的。当使用moveToThread方法将对象移动到其他线程后,对象的构造函数仍然是在主线程执行的。moveToThread方法仅仅是让对象的事件循环、信号槽连接等引用主线程的资源移动到目标线程,但对象本身是不会移动的。)

错误写法：

//主线程所在类
QThread *thread = new QThread(this);

Work *read = new Work();
read->moveToThread(thread);
connect(thread , SIGNAL(started()),read,SLOT(connectServer()));
thread->start();


//work类 构造函数
Work::work(QObject *parent) : QObject(parent)
{
    m_count = 100;
    //创建socket
    socket = new QTcpSocket(this);
    //连接服务器
    socket->connectToHost(sIP, nPort);

    //等待连接成功
    if(!socket->waitForConnected(30000))
        qDebug() << "连接失败！";

    //连接信号槽
    QObject::connect(socket,SIGNAL(connected()),this,SLOT(isConnection())); //连接
    QObject::connect(socket, &QTcpSocket::disconnected, this, &Work::socket_Disconnected);

    //断线重连定时器(======错误写法,定时器不能在构造函数里进行创建,构造函数是在主线程里======)
    timer_reConn = new QTimer();
    connect(timer_reConn,&QTimer::timeout,this,&Work::reConnection);

    qDebug() << "Connect successfully!";
}

bool Work::isConnection()
{
    while(1)
    {
        QString sData = QString("发送的数据");
        QThread::msleep(50);                    //50ms发送一次
        socket->write(sData.toLocal8Bit());
        socket->flush();

        QApplication::processEvents();          //为什么使用processEvents,请看问题2
    }
}

//work类的短线重连函数
void Work::socket_Disconnected()
{
    m_count = 0;
    timer_reConn->start(1000);               //每1秒钟自动重连 10次后停止
}

void SendDataToVC_EXERCISE::reConnection()
{
    m_count++;                //重新连接记数
    if(m_count <= 10)         //连接次数小于等于10次
    {
        qDebug()<< QString("断开连接，准备重新连接（第%1次）").arg(m_count);
        socket->connectToHost(sIP,nPort);
    }
    else                      //连接次数超过10次，停止重连
    {
        timer_reConn->stop();
    }
}

正确写法：

//主线程所在类
QThread *thread = new QThread(this);

Work *read = new Work();
read->moveToThread(thread);
connect(thread , SIGNAL(started()),read,SLOT(connectServer()));
thread->start();


//work类 构造函数
Work::work(QObject *parent) : QObject(parent)
{
    m_count = 100;
    //创建socket
    socket = new QTcpSocket(this);
    //连接服务器
    socket->connectToHost(sIP, nPort);

    //等待连接成功
    if(!socket->waitForConnected(30000))
        qDebug() << "连接失败！";

    //连接信号槽
    QObject::connect(socket,SIGNAL(connected()),this,SLOT(isConnection())); //连接
    QObject::connect(socket, &QTcpSocket::disconnected, this, &Work::socket_Disconnected);

    qDebug() << "Connect successfully!";
}

bool Work::isConnection()
{
    while(1)
    {
        QString sData = QString("发送的数据");
        QThread::msleep(50);                    //50ms发送一次
        socket->write(sData.toLocal8Bit());
        socket->flush();

        QApplication::processEvents();          //为什么使用processEvents,请看问题2
    }
}

//work类的短线重连函数
void Work::socket_Disconnected()
{
    m_count = 0;
    //断线重连定时器
    timer_reConn = new QTimer();    (======正确写法,应该写在槽函数里======)
    connect(timer_reConn,&QTimer::timeout,this,&Work::reConnection);
    timer_reConn->start(1000);               //每1秒钟自动重连 10次后停止
}

void SendDataToVC_EXERCISE::reConnection()
{
    m_count++;                //重新连接记数
    if(m_count <= 10)         //连接次数小于等于10次
    {
        qDebug()<< QString("断开连接，准备重新连接（第%1次）").arg(m_count);
        socket->connectToHost(sIP,nPort);
    }
    else                      //连接次数超过10次，停止重连
    {
        timer_reConn->stop();
    }
}

部分转载自:文三~