QT多线程示例+一种通用高并发数据处理最简单思路 - QTCN开发网

在线liudianwu

总版主

只看楼主正序阅读楼主发表于: 2015-01-31

— 本帖被 XChinux 执行加亮操作(2016-04-18) —

平时的项目程序中，经常需要处理多个串口和网络发送过来的数据，而且数据量还比较大，9600的波特率每秒钟至少1000个字节的数据需要处理并反映到界面上，一开始直接和UI主线程同一个线程，在x86的机器上跑还没问题，毕竟X86的机器最少主频也不会低于1.6G，但是如果数据量再更大或者到了ARM上跑，直接UI卡住不动，想到的解决办法就是用多线程，一个线程负责收数据，一个线程负责处理数据，当协议一样的时候，如果需要将数据解析从串口改为网络端口监听的数据，以前的办法是重新写一个tcp通信进行处理，这个并不是非常合理的办法，毕竟解析协议是一样的，所以自己总结了一个通用的数据处理思路：各种数据接收后排队的形式存入一个全局变量，单独开辟一个线程从这个全局变量中读取第一个数据，处理完则移除第一个数据，Qt中的链表直接提供了一个takeFirst函数，用起来非常爽！用while循环读取，在读取的时候加锁，这样的话就不会冲突了。
雏形：
全局变量文件：

复制代码

#ifndef APP_H
#define APP_H
#include "qstring.h"
#include "qstringlist.h"
class App
{
public:
static QStringList list;
};
#endif // APP_H

复制代码

#include "app.h"
QStringList App::list=QStringList();

独立处理数据线程：

复制代码

#ifndef TEST_H
#define TEST_H
#include "qthread.h"
#include "qmutex.h"
class Thread : public QThread
{
Q_OBJECT
public:
Thread();
~Thread();
void stop();
protected:
void run();
private:
QMutex mutex;
volatile bool stopped;
signals:
void readOne(QString txt);
};
#endif // TEST_H

复制代码

#include "thread.h"
#include "app.h"
Thread::Thread()
{
stopped=false;
}
Thread::~Thread()
{
}
void Thread::stop()
{
stopped=true;
}
void Thread::run()
{
while(!stopped){
mutex.lock();
if (App::list.count()>0){
QString txt=App::list.takeFirst();
emit readOne(txt);
}
mutex.unlock();
msleep(1);//不加这句CPU占用率高达50%
}
stopped=false;
}

主界面：

复制代码

#ifndef WIDGET_H
#define WIDGET_H
#include <QWidget>
#include "thread.h"
#include "qtimer.h"
namespace Ui {
class frmMain;
}
class frmMain : public QWidget
{
Q_OBJECT
public:
explicit frmMain(QWidget *parent = 0);
~frmMain();
private slots:
void writeOne();
void readOne(QString txt);
void on_btnAppend_clicked();
void on_btnThread_clicked();
void on_btnTimer_clicked();
private:
Ui::frmMain *ui;
QTimer *timer;
Thread *thread;
};
#endif // WIDGET_H

复制代码

#include "frmmain.h"
#include "ui_frmmain.h"
#include "app.h"
#include "qdatetime.h"
#include "qdesktopwidget.h"
#define _TIME_ qPrintable (QTime::currentTime().toString("now : hh:mm:ss:zzz"))
frmMain::frmMain(QWidget *parent) :
QWidget(parent),
ui(new Ui::frmMain)
{
ui->setupUi(this);
this->showMaximized();
timer=new QTimer(this);
timer->setInterval(50);
connect(timer,SIGNAL(timeout()),this,SLOT(writeOne()));
thread=new Thread;
connect(thread,SIGNAL(readOne(QString)),this,SLOT(readOne(QString)));
}
frmMain::~frmMain()
{
delete ui;
}
void frmMain::writeOne()
{
App::list.append(_TIME_);
}
void frmMain::readOne(QString txt)
{
ui->txtOut->append(txt);
}
void frmMain::on_btnAppend_clicked()
{
App::list.append(ui->txtIn->text());
}
void frmMain::on_btnThread_clicked()
{
if (ui->btnThread->text()=="start thread"){
thread->start();
ui->btnThread->setText("stop thread");
ui->txtOut->append("start thread ok");
}else{
thread->stop();
ui->btnThread->setText("start thread");
ui->txtOut->append("stop thread ok");
}
}
void frmMain::on_btnTimer_clicked()
{
if (ui->btnTimer->text()=="start timer"){
timer->start();
ui->btnTimer->setText("stop timer");
ui->txtOut->append("start timer ok");
}else{
timer->stop();
ui->btnTimer->setText("start timer");
ui->txtOut->append("stop timer ok");
}
}

为了模拟大量数据，我这里开了50毫秒的定时器定时产生当前时间字符串的数据存入全局变量，然后放置了几个按钮用于手动添加字符串和开始停止线程及定时器。

欢迎提出批评建议以及指点！谢谢！
代码下载：

ThreadTool.zip (6 K) 下载次数:1615

共12条评分，好评度+2 ，贡献值+3 ，金钱+5 ，威望+2

drabel	好评度 +1	优秀文章，支持！n神马都是浮云	2020-04-01
drabel	贡献值 +1	优秀文章，支持！n神马都是浮云	2020-04-01
drabel	威望 +1	优秀文章，支持！n神马都是浮云	2020-04-01
drabel	金钱 +1	优秀文章，支持！n神马都是浮云	2020-04-01
qinlian2010	好评度 +1	nice	2019-09-19
qinlian2010	贡献值 +1	nice	2019-09-19
qinlian2010	威望 +1	nice	2019-09-19
qinlian2010	金钱 +1	nice	2019-09-19
leee101	金钱 +1	-	2019-04-18
听雨陌行	贡献值 +1	-	2019-04-11

12

欢迎关注微信公众号：Qt实战/Qt入门和进阶(各种开源作品、经验整理、项目实战技巧，专注Qt/C++软件开发，视频监控、物联网、工业控制、嵌入式软件、国产化系统应用软件开发) QQ：517216493 WX：feiyangqingyun QQ群：751439350

分享到 淘江湖新浪 QQ微博 QQ空间开心人人豆瓣网易微博百度鲜果白社会飞信


	http://www.qtcn.org/bbs 访问内容超出本站范围，不能确定是否安全


	关闭您还没有登录，快捷通道只有在登录后才能使用。立即登录还没有帐号？赶紧注册一个

帖子

QT多线程示例+一种通用高并发数据处理最简单思路 [复制链接]