QT多發線程進行數據傳輸

平時的項目程序中，經常需要處理多個串口和網絡發送過來的數據，而且數據量還比較大，9600的波特率每秒鐘至少1000個字節的數據需要處理并反映到界面上，一開始直接和UI主線程同一個線程，在x86的機器上跑還沒問題，畢竟X86的機器最少主頻也不會低于1.6G，但是如果數據量再更大或者到了ARM上跑，直接UI卡住不動，想到的解決辦法就是用多線程，一個線程負責收數據，一個線程負責處理數據，當協議一樣的時候，如果需要將數據解析從串口改為網絡端口監聽的數據，以前的辦法是重新寫一個tcp通信進行處理，這個并不是非常合理的辦法，畢竟解析協議是一樣的，所以自己總結了一個通用的數據處理思路：各種數據接收后排隊的形式存入一個全局變量，單獨開辟一個線程從這個全局變量中讀取第一個數據，處理完則移除第一個數據，Qt中的鏈表直接提供了一個takeFirst函數，用起來非常爽！用while循環讀取，在讀取的時候加鎖，這樣的話就不會沖突了。
雛形：
全局變量文件：

復制代碼

1. #ifndef APP_H

2. #define APP_H

3. 
   

4. #include "qstring.h"

5. #include "qstringlist.h"

6. 
   

7. class App

8. {

9. public:    

10.     static QStringList list;

11. 
    

12. };

13. 
    

14. #endif // APP_H

復制代碼

1. #include "app.h"

2. 
   

3. QStringList App::list=QStringList();

獨立處理數據線程：

復制代碼

1. #ifndef TEST_H

2. #define TEST_H

3. 
   

4. #include "qthread.h"

5. #include "qmutex.h"

6. 
   

7. class Thread : public QThread

8. {

9.     Q_OBJECT

10. public:

11.     Thread();

12.     ~Thread();

13. 
    

14.     void stop();

15. 
    

16. protected:

17.     void run();

18. 
    

19. private:

20.     QMutex mutex;

21.     volatile bool stopped;

22. 
    

23. signals:

24.     void readOne(QString txt);

25. 
    

26. };

27. 
    

28. #endif // TEST_H

復制代碼

1. #include "thread.h"

2. #include "app.h"

3. 
   

4. Thread::Thread()

5. {

6. stopped=false;

7. }

8. 
   

9. Thread::~Thread()

10. {

11. 
    

12. }

13. 
    

14. void Thread::stop()

15. {

16.     stopped=true;

17. }

18. 
    

19. void Thread::run()

20. {

21.     while(!stopped){

22.         mutex.lock();

23.         if (App::list.count()>0){            

24.             QString txt=App::list.takeFirst();

25.             emit readOne(txt);

26.         }

27.         mutex.unlock();

28.         msleep(1);//不加這句CPU占用率高達50%

29.     }

30.     stopped=false;

31. }

主界面：

復制代碼

1. #ifndef WIDGET_H

2. #define WIDGET_H

3. 
   

4. #include <QWidget>

5. #include "thread.h"

6. #include "qtimer.h"

7. 
   

8. namespace Ui {

9. class frmMain;

10. }

11. 
    

12. class frmMain : public QWidget

13. {

14.     Q_OBJECT

15. 
    

16. public:

17.     explicit frmMain(QWidget *parent = 0);

18.     ~frmMain();

19. 
    

20. private slots:

21.     void writeOne();

22.     void readOne(QString txt);

23.     void on_btnAppend_clicked();

24.     void on_btnThread_clicked();

25.     void on_btnTimer_clicked();

26. 
    

27. private:

28.     Ui::frmMain *ui;

29. 
    

30.     QTimer *timer;

31.     Thread *thread;

32. 
    

33. };

34. 
    

35. #endif // WIDGET_H

復制代碼

1. #include "frmmain.h"

2. #include "ui_frmmain.h"

3. #include "app.h"

4. #include "qdatetime.h"

5. #include "qdesktopwidget.h"

6. 
   

7. #define _TIME_ qPrintable (QTime::currentTime().toString("now : hh:mm:ss:zzz"))

8. 
   

9. frmMain::frmMain(QWidget *parent) :

10.     QWidget(parent),

11.     ui(new Ui::frmMain)

12. {

13.     ui->setupUi(this);

14. 
    

15.     this->showMaximized();

16. 
    

17.     timer=new QTimer(this);

18.     timer->setInterval(50);

19.     connect(timer,SIGNAL(timeout()),this,SLOT(writeOne()));

20. 
    

21.     thread=new Thread;

22.     connect(thread,SIGNAL(readOne(QString)),this,SLOT(readOne(QString)));

23. }

24. 
    

25. frmMain::~frmMain()

26. {

27.     delete ui;

28. }

29. 
    

30. void frmMain::writeOne()

31. {

32.     App::list.append(_TIME_);

33. }

34. 
    

35. void frmMain::readOne(QString txt)

36. {

37.     ui->txtOut->append(txt);

38. }

39. 
    

40. void frmMain::on_btnAppend_clicked()

41. {

42.     App::list.append(ui->txtIn->text());

43. }

44. 
    

45. void frmMain::on_btnThread_clicked()

46. {

47.     if (ui->btnThread->text()=="start thread"){

48.         thread->start();

49.         ui->btnThread->setText("stop thread");

50.         ui->txtOut->append("start thread ok");

51.     }else{

52.         thread->stop();

53.         ui->btnThread->setText("start thread");

54.         ui->txtOut->append("stop thread ok");

55.     }

56. }

57. 
    

58. void frmMain::on_btnTimer_clicked()

59. {

60.     if (ui->btnTimer->text()=="start timer"){

61.         timer->start();

62.         ui->btnTimer->setText("stop timer");

63.         ui->txtOut->append("start timer ok");

64.     }else{

65.         timer->stop();

66.         ui->btnTimer->setText("start timer");

67.         ui->txtOut->append("stop timer ok");

68.     }

69. }

為了模擬大量數據，我這里開了50毫秒的定時器定時產生當前時間字符串的數據存入全局變量，然后放置了幾個按鈕用于手動添加字符串和開始停止線程及定時器。



歡迎提出批評建議以及指點！謝謝！