Qt中moveToThread注意的地方

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

例如:

class Work : public QObject 
{Q_OBJECTpublic: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;//创建socketsocket = 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;//创建socketsocket = 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();}
}

部分转载自:文三~


陌生男人犀利的目光从远处开始,到走近一直注视着我。就在我惊恐万分的时候,他转身走上了一条田埂,逐渐离我远去。宽大的黑衣由于风的掀动,发出哗哗的响声。我成年以后回顾往事时,总要长久地停留在这个地方,惊诧自己当初为何会将这哗哗的衣服声响,理解成是对那个女人黑夜雨中呼喊的回答。        《在细雨中呼喊》

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/277523.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

7. 异常、断言及日志

1.异常 1).什么是异常 异常&#xff0c;就是不正常的意思。指的是程序在执行过程中&#xff0c;出现的非正常的情况&#xff0c;最终会导致JVM的非正常停止。 在Java等面向对象的编程语言中&#xff0c;异常本身是一个类&#xff0c;产生异常就是创建异常对象并抛出了一个异常…

动态规划习题

动态规划的核心思想是利用子问题的解来构建整个问题的解。为此&#xff0c;我们通常使用一个表格或数组来存储子问题的解&#xff0c;以便在需要时进行查找和使用。 1.最大字段和 #include <iostream> using namespace std; #define M 200000int main() {int n, a[M], d…

[pluginviteimport-analysis] vite 提示jsx语法报错

参考文章 https://segmentfault.com/q/1010000043499356https://blog.csdn.net/kkkkkkgg/article/details/131168224 报错内容 内容类似如下&#xff1a; 03:16:26 [vite] Internal server error: Failed to parse source for import analysis because the content contains…

广州华锐互动:VR煤矿安全操作规程实训提升矿工安全意识与技能

随着科技的不断发展&#xff0c;虚拟现实&#xff08;VR&#xff09;技术已经逐渐渗透到各个领域&#xff0c;为人们的生活带来了极大的便利。在煤矿行业&#xff0c;VR技术的应用也日益受到重视&#xff0c;尤其是在煤矿安全检查方面。为了提高矿工的安全意识和技能&#xff0…

【CANN训练营】CANN算子开发进阶笔记

Ascend C Tilling计算 Tilling基本概念介绍 大多数情况下&#xff0c;Local Memory的存储&#xff0c;无法完全容纳算子的输入与输出的所有数据&#xff0c;需要每次搬运一部分输入数柜进行计算然后搬出&#xff0c;再敲运下一部分输入数据进行计算&#xff0c;直到得到完愁的…

windows下安装git中文版客户端

下载git Windows客户端 git客户端下载地址&#xff1a;Git - Downloads 我这里下载的是Git-2.14.0-64-bit.exe版本 下载TortoiseGit TortoiseGit客户端下载地址&#xff1a;Download – TortoiseGit – Windows Shell Interface to Git TortoiseGit客户端要下载两个&#…

JS基本语法

JS基本语法 变量数据类型原始数据类型 函数定义第一种方式第二种方式 JS 对象ArrayStringJavaScript 自定义对象JSONDOMBOM JS 事件事件监听事件绑定常见事件 变量 数据类型 原始数据类型 函数定义 第一种方式 第二种方式 JS 对象 Array String JavaScript 自定义对象 JSON …

RK3568/RV1126/RV1109/RV1106 ISP调试方案

最近一直在做瑞芯微rv1126的开发&#xff0c;由于项目性质&#xff0c;与camera打的交道比较多&#xff0c;包括图像的采集&#xff0c;ISP处理&#xff0c;图像处理&#xff0c;H.264/H.265编解码等各个方面吧。学到了不少&#xff0c;在学习的过程中&#xff0c;也得到了不少…

模拟真实内网渗透过程

环境搭建 kali为cs服务器 win11为攻击者主机 DMZ模拟目标web服务器&#xff0c;配置两块网卡&#xff0c;一个连外网&#xff0c;一个连内网域控 最终要求在win11上使用cs对目标域控进行提权 实施过程 一、域控主机搭建域环境&#xff0c;DMZ主机加入域内 搭建域控 w…

持续集成交付CICD:GitLabCI操作Harbor仓库

目录 一、实验 1.GitLabCI操作Harbor仓库 二、问题 1.gitlab-runner连接docker daemon报错 一、实验 1.GitLabCI操作Harbor仓库 &#xff08;1&#xff09;修改GitLabCI共享库代码并提交到mater CI.yaml .pipelineInit:tags:- buildstage: .prevariables:GIT_CHECKOUT: …

IDEA配置ctrl + / 快捷键注释的位置

对于一个强迫症患者来说&#xff0c;Ctrl / 这个日常使用非常频繁的快捷键默认生成的位置是在每一个的顶格位置&#xff0c;这让我非常苦恼。 刚刚找到了解决方案&#xff0c;分享一下&#xff0c;_ 在IntelliJ IDEA中&#xff0c;如果你想要注释符号紧挨着代码的第一个字母…

车载以太网笔记

文章目录 以太网协议分层协议中间设备子网掩码物理层测试内容比较杂,后续会整理。 以太网协议分层 协议 中间设备