重慶分公司
重慶分公司，新征程啟航
為企業提供網站建設、域名注冊、服務器等服務
QT多發線程進行數據傳輸-創新互聯
平時的項目程序中，經常需要處理多個串口和網絡發送過來的數據，而且數據量還比較大，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
#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毫秒的定時器定時產生當前時間字符串的數據存入全局變量，然后放置了幾個按鈕用于手動添加字符串和開始停止線程及定時器。
歡迎提出批評建議以及指點！謝謝！
另外有需要云服務器可以了解下創新互聯scvps.cn，海內外云服務器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務器、裸金屬服務器、高防服務器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業上云的綜合解決方案，具有“安全穩定、簡單易用、服務可用性高、性價比高”等特點與優勢，專為企業上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。
分享文章：QT多發線程進行數據傳輸-創新互聯
瀏覽路徑：http://www.xueling.net.cn/article/jdhco.html