qt之事件循环与线程的关系
先说重点,先了解几个重要的概念,
- 事件调度器,该调度器的具体实现与操作系统相关,不同的操作系统具有不同的实现,例如linux系统下该调度器的实现为QEventDispatcherUNIX,而window下的他们的实现为QEventDispatcherWin32,他们的目录是QTDIR/5.15.2/Src/qtbase/src/corelib/kernel目录下寻找即可。该调度器实现了事件循环的核心功能。不同操作系统的事件调度器他们的基类是同一个QAbstractEventDispatcher。
- threadData,这里就称它为线程数据吧,每个QObject都有这样一个数据成员,从这里可以看出每个QObject对象都是线程相关的。threadData包含了该对象所属线程的相关信息,其中包含了该线程的事件队列等,该数据成员可以通过qobject::movetoThread来实现转移。
- 每个线程可以启动多个事件循环(QEventLoop),但是所有的QEventLoop共享同一个事件调度器,所以在一个线程中即使启动多个事件,最终的事件循环中的事件调度器是同一个。
- 事件循环的主要功能:我自身的理解是遍历本线程的事件队列,将消息队列中的事件发送到对应对象进行处理,该事件队列的消息可以是用户发送的自定义是事件,也可以是定时器事件,也可以是对象删除删除,也可以是操作系统的发出的一些消息转换而来的事件(例如按钮的点击操作等)。
- 事件队列中存在事件压缩的概念,压缩的概念是将事件队列中相同事件id(比如定时器事件),做相同事情的事件压缩为1个事件。
话不多说,直接上源码,清晰的将事件循环与线程的关系通过代码的方式展现出来
主线程的事件循环是由下面的代码触发
QCoreApplication::exec()
exec的内部实现如下:
int QCoreApplication::exec()
{
...QEventLoop eventLoop;int returnCode = eventLoop.exec();
...return returnCode;
}
通过上面的代码可以看到,定义了一个QEventLoop对象,对该对象调用了exec方法。QEventLoop的exec简要实现如下:
int QEventLoop::exec(ProcessEventsFlags flags)
{Q_D(QEventLoop);
...while (!d->exit)processEvents(flags | WaitForMoreEvents | EventLoopExec);
...return d->returnCode;
}
由上可以看出,QEventLoop下的exec调用了processEvents方法。该方法的实现如下:
bool QEventLoop::processEvents(ProcessEventsFlags flags)
{Q_D(QEventLoop);if (!d->threadData->eventDispatcher)return false;if (flags & DeferredDeletion)QCoreApplication::sendPostedEvents(0, QEvent::DeferredDelete);return d->threadData->eventDispatcher->processEvents(flags);
}
由上可以看到在processEvent的实现中,首先判断了threadData中成员eventDispathcer是否存在,若不存在,则返回false,eventDispatcher从字面意思理解,是一个事件分发器,通过该对象指针调用其方法processEvents,到这里会有一个疑问,eventDispatcher是何时创建的呢?请看下面的代码:
QEventLoop::QEventLoop(QObject *parent): QObject(*new QEventLoopPrivate, parent)
{Q_D(QEventLoop);if (!QCoreApplication::instance() && QCoreApplicationPrivate::threadRequiresCoreApplication()) {qWarning(
"QEventLoop: Cannot be used without QApplication");} else {d->threadData.loadRelaxed()->ensureEventDispatcher();}
}
QAbstractEventDispatcher *QThreadPrivate::createEventDispatcher(QThreadData *data)
{Q_UNUSED(data);
#if defined(Q_OS_DARWIN)bool ok = false;int value = qEnvironmentVariableIntValue("QT_EVENT_DISPATCHER_CORE_FOUNDATION", &ok);if (ok && value > 0)return new QEventDispatcherCoreFoundation;elsereturn new QEventDispatcherUNIX;
#elif !defined(QT_NO_GLIB)const bool isQtMainThread = data->thread.loadAcquire() == QCoreApplicationPrivate::mainThread();if (qEnvironmentVariableIsEmpty(
"QT_NO_GLIB")&& (isQtMainThread || qEnvironmentVariableIsEmpty(
"QT_NO_THREADED_GLIB"))&& QEventDispatcherGlib::versionSupported())return new QEventDispatcherGlib;elsereturn new QEventDispatcherUNIX;
#elsereturn new QEventDispatcherUNIX;
#endif
}
可以看到,eventDispatcher是在QEventLoop对象构造的过程中创建的,注意在这里生成的eventDispatcher已经是QEventDispatcherUnix类型了。下一步就是列出事件调度器的核心实现了,这里以linux为里介绍,所以QEventDispatcherUNIX下的实现processEvents实现,源码如下所示:
bool QEventDispatcherUNIX::processEvents(QEventLoop::ProcessEventsFlags flags)
{Q_D(QEventDispatcherUNIX);……QCoreApplicationPrivate::sendPostedEvents(0, 0, d->threadData);……timespec *tm = nullptr;……d->pollfds.append(d->threadPipe.prepare());int nevents = 0;switch (qt_safe_poll(d->pollfds.data(), d->pollfds.size(), tm)) {……}return (nevents > 0);
}void QCoreApplicationPrivate::sendPostedEvents(QObject *receiver, int event_type,QThreadData *data)
{……while (i < data->postEventList.size()) {……const QPostEvent &pe = data->postEventList.at(i);++i;……QEvent *e = pe.event;QObject * r = pe.receiver;……QCoreApplication::sendEvent(r, e);}……
}
通过上面的代码可以看出,在事件调度器里面的processEvents实现中,首先调用sendPostedEvents方法将事件队列中的事件通过QCoreApplication::sendEvent调用发送给对应的对象,这里简要的提一下,sendevent方法是一个阻塞型的方法调用,仅用于本线程内的调用,他的内部内部核心实现是函数调用,即通过接收对象receiver的指针调用该对象的event方法,但是需要注意的是在调用event方法之前首先要调用该对象注册的事件监听器对象eventfilter方法。我会单独列出一个文章讲解sendevent,详细实现将在里面实现。
然后后调用了poll相关的方法,里面射击了threadPipe的相关用法,我通过查看资料了解到的是下面的实现会导致该循环让出cpu,等待事件队列中有属于再进行工作,这一块我需要再研究下后续补充。
总结
至此,我们了解了一个事件循环的本质及与事件循环与线程的关系:
- 事件循环与线程密不可分,虽然在一个线程中可以启动多个事件循环,但是这些事件循环共享同一个threadData,也就是说在一个线程内无论启动多少个事件循环,他们操作的是都是同一个事件调度器,并不会因为启动多个事件队列,而导致别的事件队列无法接收数据。
- 事件循环的本质就是将事件队列中的事件一一发送到本线程中的各个对象中进行处理
- 每个QObject对象都是线程相关的,每个QObject对象都存在一个threadData成员,这个成员包含了这个对象所属的线程信息
相关文章:
qt之事件循环与线程的关系
先说重点,先了解几个重要的概念, 事件调度器,该调度器的具体实现与操作系统相关,不同的操作系统具有不同的实现,例如linux系统下该调度器的实现为QEventDispatcherUNIX,而window下的他们的实现为QEventDis…...

Python 变量的定义和数据类型的转换
变量 变量的定义 基本语法:变量名 值 变量名是给对象贴一个用于访问的标签,给对象绑定名字的过程也称为赋值,赋值符号 “” 变量名自定义,要满足标识符命名规则。 Python中,不需要事先声明变量名及其类型ÿ…...
Android Java JVM常见问答分析与总结
一、JVM是什么 JVM是JavaVirtualMachine(Java虚拟机)的缩写,JVM是一种用于计算设备的规范,它是一个虚构出来的计算机,是通过在实际的计算机上仿真模拟各种计算机功能来实现的。 JVM的重要性 JVM这块是一个偏向于概念模…...
【业务功能篇102】springboot+mybatisPlus分页查询,统一返回封装规范
业务场景: 随着业务代码量增多,很多接口查询的分页写法各种各样,为了使项目工程代码易于维护,我们统一规范,相对没有那么复杂的接口,我们统一都在java的service实现类中,去完成分页查询的接口逻…...

中国手机新进程:折叠屏出海的荣耀,5G中回归的华为
最近,“华为5G回归”“自研麒麟芯片回归”的消息引爆网络。网友开心庆贺之余,也纷纷猜测,华为强势归来,哪家友商最慌? “华为的回归,让竞争充满了更多的可能性和更多的魅力”,与华为渊源颇深的…...

安装RabbitMQ的各种问题(包括已注册成windows服务后,再次重新安装,删除服务重新注册遇到的问题)
一、安装Erlang(傻瓜式安装) 安装完成之后,配置环境变量: 1.新建系统变量名为:ERLANG_HOME 变量值为erlang安装地址 2. 双击系统变量path,点击“新建”,将%ERLANG_HOME%\bin加入到path中。 …...

多线程与高并发——并发编程(6)
文章目录 六、并发集合1 ConcurrentHashMap1.1 存储结构1.2 存储操作1.2.1 put方法1.2.2 putVal方法-散列算法1.2.3 putVal方法-添加数据到数组&初始化数组1.2.4 putVal方法-添加数据到链表1.3 扩容操作1.3.1 treeifyBin方法触发扩容1.3.2 tryPresize方法-针对putAll的初始…...

Elasticsearch——Docker单机部署安装
文章目录 1 简介2 Docker安装与配置2.1 安装Docker2.2 配置Docker镜像加速器2.3 调整Docker资源限制 3 准备Elasticsearch Docker镜像3.1 下载Elasticsearch镜像3.2 自定义镜像配置3.3执行Docker Compose 4 运行Elasticsearch容器4.1 创建Elasticsearch容器4.2 修改配置文件4.3…...

基于AHP模型指标权重分析python整理
一 背景介绍 日常会有很多定量分析的场景,然而也会有一些定性分析的场景针对定性分析的场景,预测者只能通过主观判断分析能力来推断事物的性质和发展趋势然而针对个人的直觉和虽然能够有一定的协助判断效果,但是很难量化到指标做后期的复用 …...

用python实现基本数据结构【02/4】
*说明 如果需要用到这些知识却没有掌握,则会让人感到沮丧,也可能导致面试被拒。无论是花几天时间“突击”,还是利用零碎的时间持续学习,在数据结构上下点功夫都是值得的。那么Python 中有哪些数据结构呢?列表、字典、集…...

蓝牙Mesh专有DFU
蓝牙Mesh专有DFU Mesh专有DFU协议介绍特征DFU模式和类型角色并发传输混合设备的网络传输速率后台操作传输分区内存映射安全DFU固件IDApplication firmware IDSoftDevice firmware IDBootloader firmware ID 设备页面格式内容 Mesh专有DFU协议介绍 设备固件更新(Device Firmwar…...

浅谈综合管廊智慧运维管理平台应用研究
贾丽丽 安科瑞电气股份有限公司 上海嘉定 201801 摘要:为提升综合管廊运维管理水平,实现管理的数字化转型,采用综合监测系统、BIMGIS 可视化系统、智能机器人巡检、结构安全监测等技术,搭建实时监控、应急管理、数据分析等多功能…...
Httpservletrequest与Httpservletresponse
目录 一、Httpservletrequest 1.1什么是Httpservletrequest 1.2Httpservletrequest中的方法 二、Httpservletresponse 1.1什么是Httpservletresponse 1.2Httpservletresponse的方法 一、Httpservletrequest 1.1什么是Httpservletrequest HttpServletRequest(…...

文件上传之图片码混淆绕过(upload的16,17关)
目录 1.upload16关 1.上传gif loadup17关(文件内容检查,图片二次渲染) 1.上传gif(同上面步骤相同) 2.条件竞争 1.upload16关 1.上传gif imagecreatefromxxxx函数把图片内容打散,,但是不会…...

Jetsonnano B01 笔记5:IIC通信
今日继续我的Jetsonnano学习之路,今日学习的是IIC通信,并尝试使用Jetson读取MPU6050陀螺仪数据。文章提供源码。文章主要是搬运的官方PDF说明,这里结合自己实际操作作笔记。 目录 IIC通信: IIC硬件连线: 安装IIC库文…...

【网络爬虫笔记】爬虫Robots协议语法详解
Robots协议是指一个被称为Robots Exclusion Protocol的协议。该协议的主要功能是向网络蜘蛛、机器人等搜索引擎爬虫提供一个标准的访问控制机制,告诉它们哪些页面可以被抓取,哪些页面不可以被抓取。本文将进行爬虫Robots协议语法详解,同时提供…...

MATLAB 2022b 中设置关闭 MATLAB 之前进行询问
在 MATLAB 2022b 中可以进行设置,在关闭 MATLAB 之前进行询问,防止意外关闭 MATLAB。如图:...
在SpringBoot框架下,接口有读个实现类,在不改变任何源码的情况下,SpringBoot怎么知道给接口注入哪个实现类的依赖呢?
在Spring Boot框架下,当一个接口有多个实现类时,Spring Boot 默认情况下不知道要注入哪个实现类的依赖。因此,你需要使用一些方法来明确告诉Spring Boot应该注入哪个实现类的依赖。 以下是一些常用的方法: 1.使用Qualifier注解&a…...

探索数据库管理的利器 - PHPMyAdmin
有一个项目,后端由博主独自负责,最近需要将项目交接给另一位同事。在项目初期,博主直接在数据库中使用工具创建了相关表格,并在完成后利用PhpMyAdmin生成了一份数据字典,供团队使用。然而,在随后的开发过程…...

大数据技术原理与应用学习笔记第1章
黄金组合访问地址:http://dblab.xmu.edu.cn/post/7553/ 1.《大数据技术原理与应用》教材 官网:http://dblab.xmu.edu.cn/post/bigdata/ 2.大数据软件安装和编程实践指南 官网林子雨编著《大数据技术原理与应用》教材配套大数据软件安装和编程实践指…...

【Python】 -- 趣味代码 - 小恐龙游戏
文章目录 文章目录 00 小恐龙游戏程序设计框架代码结构和功能游戏流程总结01 小恐龙游戏程序设计02 百度网盘地址00 小恐龙游戏程序设计框架 这段代码是一个基于 Pygame 的简易跑酷游戏的完整实现,玩家控制一个角色(龙)躲避障碍物(仙人掌和乌鸦)。以下是代码的详细介绍:…...

盘古信息PCB行业解决方案:以全域场景重构,激活智造新未来
一、破局:PCB行业的时代之问 在数字经济蓬勃发展的浪潮中,PCB(印制电路板)作为 “电子产品之母”,其重要性愈发凸显。随着 5G、人工智能等新兴技术的加速渗透,PCB行业面临着前所未有的挑战与机遇。产品迭代…...

中南大学无人机智能体的全面评估!BEDI:用于评估无人机上具身智能体的综合性基准测试
作者:Mingning Guo, Mengwei Wu, Jiarun He, Shaoxian Li, Haifeng Li, Chao Tao单位:中南大学地球科学与信息物理学院论文标题:BEDI: A Comprehensive Benchmark for Evaluating Embodied Agents on UAVs论文链接:https://arxiv.…...
线程同步:确保多线程程序的安全与高效!
全文目录: 开篇语前序前言第一部分:线程同步的概念与问题1.1 线程同步的概念1.2 线程同步的问题1.3 线程同步的解决方案 第二部分:synchronized关键字的使用2.1 使用 synchronized修饰方法2.2 使用 synchronized修饰代码块 第三部分ÿ…...
【决胜公务员考试】求职OMG——见面课测验1
2025最新版!!!6.8截至答题,大家注意呀! 博主码字不易点个关注吧,祝期末顺利~~ 1.单选题(2分) 下列说法错误的是:( B ) A.选调生属于公务员系统 B.公务员属于事业编 C.选调生有基层锻炼的要求 D…...

涂鸦T5AI手搓语音、emoji、otto机器人从入门到实战
“🤖手搓TuyaAI语音指令 😍秒变表情包大师,让萌系Otto机器人🔥玩出智能新花样!开整!” 🤖 Otto机器人 → 直接点明主体 手搓TuyaAI语音 → 强调 自主编程/自定义 语音控制(TuyaAI…...

用docker来安装部署freeswitch记录
今天刚才测试一个callcenter的项目,所以尝试安装freeswitch 1、使用轩辕镜像 - 中国开发者首选的专业 Docker 镜像加速服务平台 编辑下面/etc/docker/daemon.json文件为 {"registry-mirrors": ["https://docker.xuanyuan.me"] }同时可以进入轩…...

视觉slam十四讲实践部分记录——ch2、ch3
ch2 一、使用g++编译.cpp为可执行文件并运行(P30) g++ helloSLAM.cpp ./a.out运行 二、使用cmake编译 mkdir build cd build cmake .. makeCMakeCache.txt 文件仍然指向旧的目录。这表明在源代码目录中可能还存在旧的 CMakeCache.txt 文件,或者在构建过程中仍然引用了旧的路…...

Kafka入门-生产者
生产者 生产者发送流程: 延迟时间为0ms时,也就意味着每当有数据就会直接发送 异步发送API 异步发送和同步发送的不同在于:异步发送不需要等待结果,同步发送必须等待结果才能进行下一步发送。 普通异步发送 首先导入所需的k…...

STM32HAL库USART源代码解析及应用
STM32HAL库USART源代码解析 前言STM32CubeIDE配置串口USART和UART的选择使用模式参数设置GPIO配置DMA配置中断配置硬件流控制使能生成代码解析和使用方法串口初始化__UART_HandleTypeDef结构体浅析HAL库代码实际使用方法使用轮询方式发送使用轮询方式接收使用中断方式发送使用中…...