当前位置: 首页 > news >正文

关于Qt在子线程中使用通讯时发生无法接收数据的情况

在多线程应用中,串口通讯或TCP通讯的场景常常涉及到持续的读写操作,如果子线程处理不当,可能会导致信号阻塞问题。本文将通过串口通讯或TCP通讯为例,详细解释如何在多线程环境中避免信号阻塞,并提供代码示例。

1. 问题背景

假设我们在一个应用程序中使用多线程处理串口或TCP通讯,通常会在子线程中实现持续的数据读取。为了确保实时处理数据,常见的做法是在子线程的 run() 方法中使用 while 循环。然而,如果没有正确处理事件循环,子线程可能会出现无法接收信号或阻塞的现象。

串口或TCP通讯的基本结构

通常,串口或TCP通讯的流程如下:

  • 子线程负责监听串口或TCP端口,接收数据。
  • 主线程通过信号槽机制向子线程发送控制命令。
  • 子线程接收到命令后执行相应操作,并将结果通过信号传回主线程。

2. 常见信号阻塞现象

在没有处理事件循环的情况下,子线程执行如下代码:

示例:阻塞信号的串口通讯
class SerialThread : public QThread {Q_OBJECT
public:SerialThread() {// 连接信号和槽connect(this, &SerialThread::dataReceived, this, &SerialThread::handleData);}signals:void dataReceived(const QByteArray &data); // 数据接收信号public slots:void handleData(const QByteArray &data) {qDebug() << "Data received in thread:" << data;}protected:void run() override {QSerialPort serial;  // 假设使用Qt的QSerialPort类serial.setPortName("COM1");serial.setBaudRate(QSerialPort::Baud115200);if (!serial.open(QIODevice::ReadWrite)) {qDebug() << "Failed to open serial port!";return;}while (true) {if (serial.waitForReadyRead(1000)) { // 等待数据到来QByteArray data = serial.readAll();emit dataReceived(data); // 发出数据接收信号}}}
};

问题分析:

在上述代码中,子线程通过 while 循环不断监听串口数据,数据到达时发出 dataReceived 信号。然而,由于线程在 while 循环中没有进入事件循环,其他信号(例如来自主线程的控制命令)可能无法被处理,导致信号阻塞。

示例:阻塞信号的TCP通讯
class TcpThread : public QThread {Q_OBJECT
public:TcpThread() {connect(this, &TcpThread::messageReceived, this, &TcpThread::handleMessage);}signals:void messageReceived(const QString &message); // 接收TCP消息的信号public slots:void handleMessage(const QString &message) {qDebug() << "Message received in thread:" << message;}protected:void run() override {QTcpSocket socket;socket.connectToHost("127.0.0.1", 8080);if (!socket.waitForConnected(3000)) {qDebug() << "Failed to connect!";return;}while (true) {if (socket.waitForReadyRead(1000)) {QString message = socket.readAll();emit messageReceived(message); // 发出消息接收信号}}}
};

这里的问题与串口通讯类似,while 循环导致线程无法进入事件循环,可能会阻塞信号的处理。

3. 使用 QEventLoop 解决信号阻塞问题

为了避免信号阻塞,我们可以在 while 循环中使用 QEventLoop。这种方式确保了线程在执行任务的同时,仍然能够处理来自其他对象的信号。

示例:使用 QEventLoop 的串口通讯
class SerialThread : public QThread {Q_OBJECT
public:SerialThread() {connect(this, &SerialThread::dataReceived, this, &SerialThread::handleData);}signals:void dataReceived(const QByteArray &data);public slots:void handleData(const QByteArray &data) {qDebug() << "Data received in thread:" << data;}protected:void run() override {QSerialPort serial;serial.setPortName("COM1");serial.setBaudRate(QSerialPort::Baud115200);if (!serial.open(QIODevice::ReadWrite)) {qDebug() << "Failed to open serial port!";return;}QEventLoop eventLoop;while (true) {if (serial.waitForReadyRead(1000)) {QByteArray data = serial.readAll();emit dataReceived(data); // 发出信号}// 每次等待任务时启动局部事件循环QTimer::singleShot(10, &eventLoop, &QEventLoop::quit);eventLoop.exec();  // 进入事件循环以处理信号}}
};
示例:使用 QEventLoop 的TCP通讯
class TcpThread : public QThread {Q_OBJECT
public:TcpThread() {connect(this, &TcpThread::messageReceived, this, &TcpThread::handleMessage);}signals:void messageReceived(const QString &message);public slots:void handleMessage(const QString &message) {qDebug() << "Message received in thread:" << message;}protected:void run() override {QTcpSocket socket;socket.connectToHost("127.0.0.1", 8080);if (!socket.waitForConnected(3000)) {qDebug() << "Failed to connect!";return;}QEventLoop eventLoop;while (true) {if (socket.waitForReadyRead(1000)) {QString message = socket.readAll();emit messageReceived(message); // 发出信号}QTimer::singleShot(10, &eventLoop, &QEventLoop::quit);eventLoop.exec(); // 进入事件循环以处理信号}}
};

4. 总结

通过上述示例可以看出,在 Qt 的多线程通讯场景下,使用 while 循环容易导致信号的阻塞。引入局部事件循环(QEventLoop)可以有效解决这一问题,确保线程既能执行持续的任务,也能及时响应来自其他对象的信号。

使用局部事件循环的好处:

  • 保持线程内任务的执行不被打断。
  • 确保信号槽机制正常工作,信号不会被阻塞。
  • 提升程序的响应性,特别是在处理通讯时尤为重要。

相关文章:

关于Qt在子线程中使用通讯时发生无法接收数据的情况

在多线程应用中&#xff0c;串口通讯或TCP通讯的场景常常涉及到持续的读写操作&#xff0c;如果子线程处理不当&#xff0c;可能会导致信号阻塞问题。本文将通过串口通讯或TCP通讯为例&#xff0c;详细解释如何在多线程环境中避免信号阻塞&#xff0c;并提供代码示例。 1. 问题…...

HTML:从历史演进到未来创新的网页基石

该论文为AI生成&#xff0c;请勿运用到正式的论文上&#xff0c;以下仅供参考 一、引言 1.1 研究背景 HTML&#xff08;Hypertext Markup Language&#xff09;作为网页构建的基础语言&#xff0c;在互联网的发展历程中占据着至关重要的地位。自 1993 年诞生以来&#xff0c…...

向量的叉积、点积、外积

向量的叉积、点积和外积是向量代数中非常重要的操作,用于描述向量间的关系。它们广泛应用于物理、计算机图形学、几何以及蛋白质结构分析等领域。下面对每个运算进行详细介绍,并通过 PyTorch 示例代码展示其实现。 1. 点积 (Dot Product) 点积是两个向量之间的数量积,结果…...

UNI-APP 溢出隐藏显示省略号

✍经常在项目里面使用到&#xff0c;又没有记住懒得找了&#xff0c;故此写一篇记录一下! CSS单行显示省略号 /* CSS样式 */ .ellipsis {overflow: hidden; /* 隐藏超出的内容 */text-overflow: ellipsis; /* 显示省略号 */white-space: nowrap; /* 不换行 */ } CS…...

SAP学习笔记 - 开发03 - CDSView开发环境搭建,Eclipse中连接SAP,CDSView创建

上一章讲了BTP的账号创建&#xff0c;环境搭建等内容。 SAP学习笔记 - 开发02 - BTP实操流程&#xff08;账号注册&#xff0c;BTP控制台&#xff0c;BTP集成开发环境搭建&#xff09;-CSDN博客 本章继续讲SAP开发。 - CDSView 的开发环境&#xff08;Eclipse&#xff09;搭建…...

uniapp写的一个年月日时分秒时间选择功能

代码: <template><view><picker mode"multiSelector" :value"multiIndex" :range"multiRange" change"onMultiChange"><view class"picker">当前选择&#xff1a;{{ formattedDateTime }}</vie…...

golang hertz框架入门

两种模式新建项目 1、手动新建项目 2、使用hz工具新建项目 一、手动创建项目&#xff0c;并拉取框架 1、新建项目目录 hertz_demo_w 2、在项目跟目录新建main.go 文件 package mainimport ("context""github.com/cloudwego/hertz/pkg/app""github.…...

Android Home应用程序启动流程

Android系统在启动时安装应用程序的过程&#xff0c;这些应用程序安装好之后&#xff0c;还需要有一个Home应用程序来负责把它们在桌面上展示出来&#xff0c;在Android系统中&#xff0c;这个默认的Home应用程序就是Launcher了&#xff0c;本文将详细分析Launcher应用程序的启…...

C++笔试强训12、13、14

文章目录 笔试强训12一、选择题1-5题6-10题 二、编程题题目一题目二 笔试强训13一、选择题1-5题6-10题 二、编程题题目一题目二 笔试强训14一、选择题1-5题6-10题 二、编程题题目一题目二 笔试强训12 一、选择题 1-5题 引用&#xff1a;是一个别名&#xff0c;与其被引用的实…...

Excel和Word日常使用记录:

Excel使用总结 表格颜色填充&#xff1a; 合并单元格&#xff1a; 选中你要合并的单元格区域。 按下快捷键 Alt H&#xff0c;然后松开这些键。 再按下 M&#xff0c;接着按 C。 这个组合键执行的操作是&#xff1a;Alt H&#xff1a;打开“主页”选项卡。 M&#xff1a;选…...

用Git把本地仓库上传到远程仓库

用Git把本地仓库上传到远程仓库 GitHub创建远程仓库 在创建新仓库界面里输入你的仓库名后点击Create repository就好了。 创建本地项目 当你已经有一个项目后在命令行输入如下指令即可 git init git commit -m "first commit" git branch -M main git remote a…...

OneHotEncoder一个不太合理的地方

OneHotEncoder&#xff0c;在Xtrain上fit&#xff0c;在Xtest上transform 如果遇到某个值出现在Xtest&#xff0c;而没有在Xtrain出现过时&#xff0c;会抛出如下错误&#xff1a; OneHotEncoder Found unknown categories [xxx] in column xx during transform OneHotEncoder …...

如何修复软件中的BUG

笔者上一篇博文《如何开发出一款优秀的软件》主要讲了如何开发一款优秀的软件及相应的必要条件。但对一个已上线&#xff0c;已经成型的产品&#xff0c;该如何解决存在的bug呢&#xff1f;这是本文要阐述的内容。 在这里&#xff0c;首先说一下bug的种类及bug严重程度分类&…...

分享一个基于微信小程序的医院挂号就诊一体化平台uniapp医院辅助挂号应用小程序设计(源码、调试、LW、开题、PPT)

&#x1f495;&#x1f495;作者&#xff1a;计算机源码社 &#x1f495;&#x1f495;个人简介&#xff1a;本人 八年开发经验&#xff0c;擅长Java、Python、PHP、.NET、Node.js、Android、微信小程序、爬虫、大数据、机器学习等&#xff0c;大家有这一块的问题可以一起交流&…...

HTML生日蛋糕

目录 写在前面 完整代码 代码分析 系列文章 写在最后 写在前面 HTML实现的生日蛋糕来喽&#xff0c;小编亲测&#xff0c;发给好友可以直接打开哦。在代码的第183行可以写下对朋友的祝福&#xff0c;快拿去送给你的好朋友吧&#xff01; 完整代码 <!DOCTYPE html>…...

【软件逆向】第27课,软件逆向安全工程师之(二)寄存器寻址,每天5分钟学习逆向吧!

寄存器寻址是汇编语言中的一种寻址方式&#xff0c;在这种方式中&#xff0c;操作数位于CPU的寄存器中。寄存器是CPU内部的高速存储位置&#xff0c;用于快速访问数据。以下是关于寄存器寻址的详细信息&#xff1a; 寄存器寻址的特点&#xff1a; 操作数在寄存器中&#xff1…...

前缀和 — 利用前缀信息解决子数组问题

【前缀和的核心思想是预先处理数组来快速计算任意子数组的和&#xff0c;基本上用于数组和序列问题。】 前缀和算法具体步骤 构造前缀和数组&#xff1a; 给定一个数组nums&#xff0c;其前缀和数组prex定义为prex[i]表示为数组nums从起始位置到第i个位置的元素累加和。构建前…...

2024年最新版Ajax+Axios 学习【包含原理、Promise、报文、接口等...】

基础知识 AJAX概念 AJAX概念&#xff1a;是浏览器与服务器进行数据通信的技术。 认识URL 定义&#xff1a;统一资源定位符&#xff0c;简称网址&#xff0c;用于访问网络上的资源。 组成&#xff1a; http协议&#xff1a;超文本传输协议&#xff0c;规定浏览器和服务器之…...

【Qt线程】—— Qt线程详解

目录 &#xff08;一&#xff09;多线程的概述 &#xff08;二&#xff09;Qt线程的使用条件 &#xff08;三&#xff09;创建线程的方法 3.1 继承QTread&#xff0c;重写run()函数 3.1.1 为什么要重写 3.2 继承QObject 3.3 核心API介绍 3.4 关闭线程的使用方法 &…...

Golang | Leetcode Golang题解之第391题完美矩形

题目&#xff1a; 题解&#xff1a; func isRectangleCover(rectangles [][]int) bool {type point struct{ x, y int }area, minX, minY, maxX, maxY : 0, rectangles[0][0], rectangles[0][1], rectangles[0][2], rectangles[0][3]cnt : map[point]int{}for _, rect : range…...

RocketMQ延迟消息机制

两种延迟消息 RocketMQ中提供了两种延迟消息机制 指定固定的延迟级别 通过在Message中设定一个MessageDelayLevel参数&#xff0c;对应18个预设的延迟级别指定时间点的延迟级别 通过在Message中设定一个DeliverTimeMS指定一个Long类型表示的具体时间点。到了时间点后&#xf…...

进程地址空间(比特课总结)

一、进程地址空间 1. 环境变量 1 &#xff09;⽤户级环境变量与系统级环境变量 全局属性&#xff1a;环境变量具有全局属性&#xff0c;会被⼦进程继承。例如当bash启动⼦进程时&#xff0c;环 境变量会⾃动传递给⼦进程。 本地变量限制&#xff1a;本地变量只在当前进程(ba…...

简易版抽奖活动的设计技术方案

1.前言 本技术方案旨在设计一套完整且可靠的抽奖活动逻辑,确保抽奖活动能够公平、公正、公开地进行,同时满足高并发访问、数据安全存储与高效处理等需求,为用户提供流畅的抽奖体验,助力业务顺利开展。本方案将涵盖抽奖活动的整体架构设计、核心流程逻辑、关键功能实现以及…...

数据库分批入库

今天在工作中&#xff0c;遇到一个问题&#xff0c;就是分批查询的时候&#xff0c;由于批次过大导致出现了一些问题&#xff0c;一下是问题描述和解决方案&#xff1a; 示例&#xff1a; // 假设已有数据列表 dataList 和 PreparedStatement pstmt int batchSize 1000; // …...

Element Plus 表单(el-form)中关于正整数输入的校验规则

目录 1 单个正整数输入1.1 模板1.2 校验规则 2 两个正整数输入&#xff08;联动&#xff09;2.1 模板2.2 校验规则2.3 CSS 1 单个正整数输入 1.1 模板 <el-formref"formRef":model"formData":rules"formRules"label-width"150px"…...

【Java学习笔记】BigInteger 和 BigDecimal 类

BigInteger 和 BigDecimal 类 二者共有的常见方法 方法功能add加subtract减multiply乘divide除 注意点&#xff1a;传参类型必须是类对象 一、BigInteger 1. 作用&#xff1a;适合保存比较大的整型数 2. 使用说明 创建BigInteger对象 传入字符串 3. 代码示例 import j…...

[免费]微信小程序问卷调查系统(SpringBoot后端+Vue管理端)【论文+源码+SQL脚本】

大家好&#xff0c;我是java1234_小锋老师&#xff0c;看到一个不错的微信小程序问卷调查系统(SpringBoot后端Vue管理端)【论文源码SQL脚本】&#xff0c;分享下哈。 项目视频演示 【免费】微信小程序问卷调查系统(SpringBoot后端Vue管理端) Java毕业设计_哔哩哔哩_bilibili 项…...

Selenium常用函数介绍

目录 一&#xff0c;元素定位 1.1 cssSeector 1.2 xpath 二&#xff0c;操作测试对象 三&#xff0c;窗口 3.1 案例 3.2 窗口切换 3.3 窗口大小 3.4 屏幕截图 3.5 关闭窗口 四&#xff0c;弹窗 五&#xff0c;等待 六&#xff0c;导航 七&#xff0c;文件上传 …...

如何更改默认 Crontab 编辑器 ?

在 Linux 领域中&#xff0c;crontab 是您可能经常遇到的一个术语。这个实用程序在类 unix 操作系统上可用&#xff0c;用于调度在预定义时间和间隔自动执行的任务。这对管理员和高级用户非常有益&#xff0c;允许他们自动执行各种系统任务。 编辑 Crontab 文件通常使用文本编…...

TSN交换机正在重构工业网络,PROFINET和EtherCAT会被取代吗?

在工业自动化持续演进的今天&#xff0c;通信网络的角色正变得愈发关键。 2025年6月6日&#xff0c;为期三天的华南国际工业博览会在深圳国际会展中心&#xff08;宝安&#xff09;圆满落幕。作为国内工业通信领域的技术型企业&#xff0c;光路科技&#xff08;Fiberroad&…...