VC++下對大量實時數(shù)據(jù)的采集處理

1、VC+下對大量實時數(shù)據(jù)的采集處理論文導(dǎo)讀：下面以VisualC+以下簡稱VC+)為例，說明采用多線程的處理方式。關(guān)鍵詞：VC+，實時數(shù)據(jù)，采集1.問題的提出隨著自動化水平的日益提高，許多工業(yè)過程控制都采用了二級或多級計算機(jī)系統(tǒng)進(jìn)行處理。在這些控制場合中，DDC一般都有串行口，通過它們可以方便地進(jìn)行數(shù)據(jù)傳輸，上位機(jī)采用面向?qū)ο蟮恼Z言，設(shè)計一個友好的人機(jī)界面，這樣一來，我們就可以很方便的在控制室的計算機(jī)上對現(xiàn)場數(shù)據(jù)進(jìn)行監(jiān)控，可隨時統(tǒng)計生產(chǎn)數(shù)據(jù)，動態(tài)顯示、存儲和輸出生產(chǎn)報表等。對于這樣一個有著非常友好人機(jī)界面的系統(tǒng)，如果它以圖形、圖像的方式來顯示設(shè)備的狀況，那么系統(tǒng)要花相當(dāng)?shù)腃PU時間去處理這一部分

2、。特別對于實時系統(tǒng)或采樣頻率較高、每幀數(shù)據(jù)量又很大的系統(tǒng)，若采用單線程處理，系統(tǒng)的響應(yīng)時間，屏幕的刷新時間都會增加，導(dǎo)致系統(tǒng)性能降低。但是如果采用多線程方式處理，效果就會好得多。發(fā)表論文。發(fā)表論文。下面以Visual C+以下簡稱VC+)為例，說明采用多線程的處理方式。2.系統(tǒng)的設(shè)計實施在VC+中，開發(fā)串行通信主要有以下四種方式:（1）用V C+提供的串行口通信控件M5Comm，它簡單易用，但不靈活;（2）用單線程的方法實現(xiàn)自定義串口通信類(封裝API)，它比MSComm要簡單，可用于簡單系統(tǒng)；（3）用多線程的方法實現(xiàn)自定義串行通信類，這種方法較靈活，且CPU利用率高；（4）直接讀寫串行口(自

3、己編寫驅(qū)動程序)，這需要編寫大量的底層軟件，較復(fù)雜。在我們的系統(tǒng)中采用了多線程方式，DDC不斷地將數(shù)據(jù)傳送給上位機(jī)，上位計算機(jī)采用被動接收數(shù)據(jù)的方式，主線程用來處理現(xiàn)場數(shù)據(jù)的統(tǒng)計、數(shù)據(jù)的存儲與輸出，以及用戶界面的消息處理。此外，再設(shè)兩個線程，線程1(RxThreadFunc)用來監(jiān)視串行口，采集數(shù)據(jù)并將數(shù)據(jù)存放到一個環(huán)形緩沖區(qū)中。線程2 (Handle ThreadFunc)用來從環(huán)形緩沖區(qū)中取數(shù)據(jù)進(jìn)行動態(tài)顯示和保存數(shù)據(jù)。系統(tǒng)首先對兩個線程進(jìn)行說明，然后創(chuàng)建它們，具體過程如下：在頭文件中說明。發(fā)表論文。static UINT RxThreadFunc(LPVOID)；static UINT H

4、andle ThreadFunc(LPVOID)；程序初始化時可加入如下代碼創(chuàng)建線程。CWin Thread*_p RxThread；CWin Thread*_p Handle Thread；_pRxThread=AfxBeginThread(RxThreadFunc，NULL，THREAD_PRIORITY_NORMAL，0，0，/Start the thread immediately after creationNULL)；_pHandle Thread= AfxBeginThread(Handle ThreadFunc，NULL，TH READ_PRIORITY_NORMAL，0，0，

5、/Start the thread immediately after creationNULL)；這樣創(chuàng)建后，這種兩個線程就可以和主線程并發(fā)執(zhí)行了，設(shè)備數(shù)據(jù)顯示的動態(tài)刷新和用戶界面消息的處理也就可以獨(dú)立的運(yùn)行。AfxBeginThread各參數(shù)的含義可參考微軟的MSDN。主線程及線程2 (Handle ThreadFunc)與一般的編程處理并無二樣，所以下面著重說明接收數(shù)據(jù)線程(RxThreadFunc )。首先生成一個串行口操作類，串行口類構(gòu)造函數(shù)如下:CCommunication：CCommunication ( ) m_hComm=NULL;m_bOpened=false;BaudRa

6、te=CBR_9600;ByteSize=8;fParity=FALSE;Parity=NOPARITY;StopBits=ONESTOPBIT;它的讀操作如下：Int CCommunication：CComRead (LPVOID pData，intn nLen)DWORD dwBytesRead;DWORD dwError;COMSTAT ComStat;if(m_hComm=NULL) return-1;if(!ReadFile(mhComm,(LPVOID)pData,nLen,&dwBytesRead,NULL)dwError=GetLastError( );If(dwBytesRe

7、ad(DWORD)nLen)ClearCommError (m_hComm，&dwError, &ComStat);return dwBytesRead;接收線程程序如下(在啟動線程之前應(yīng)先打開串口)：CCommunication vSerialPort;UINTRxThreadFunc(LPVOID ThreadArg)DWORD dwArg=*(DWORD*)ThreadArg;unsigned char temparr10;while(1) if( vSerialPort.ComRead(&emparr,l)0) /也可讀入多個字節(jié)vCircBuf.AddItem s (&temparr,1) ;/存入緩沖區(qū)中elseSleep(0) :return 0 ;程序中vCircBuf為對緩沖區(qū)操作類，此緩沖區(qū)為臨界資源，應(yīng)互斥使用。當(dāng)然程序在此也可對讀入的數(shù)據(jù)進(jìn)行其他方式的處理。3.結(jié)束語我們用一個RxThreadFunc( LPVOIDThreadArg)工作線程在后臺單獨(dú)接收數(shù)據(jù)，