2. 程式人生 > >串列埠通訊-----串列埠監聽執行緒全域性函式(C++)

串列埠通訊-----串列埠監聽執行緒全域性函式(C++)

阿新 • • 發佈：2019-02-08
``````` #include "windows.h" #define COMMBUFFER_SIZE 18 //每組資料位元組數 //串列埠變數 HANDLE g_hComm = INVALID_HANDLE_VALUE;//串列埠控制代碼 HANDLE g_hCommThread = NULL;//執行緒控制代碼 OVERLAPPED m_overlappedRead; CString m_receive;//獲取串列埠資訊; //函式初始化時 BOOL CDetectionCarDoorDlg::OnInitDialog() { ````````` bool portStat = openPort(); if
(!portStat) { AfxMessageBox(L"串列埠初始化失敗!"); } //建立資料接收執行緒; g_hCommThread = CreateThread(NULL,0,ThreadCommRecvData,this,0,0); if (g_hCommThread == NULL) { MessageBox(L"掃碼槍資料接收執行緒建立失敗"); } } /////////////////////////////////////////// //串列埠監聽執行緒全域性函式 ////////////////////////////////////////// DWORD WINAPI ThreadCommRecvData( LPVOID lpParam ) { DWORD dwEvtMask = 0
; BOOL bResult = TRUE; int bytesComm = COMMBUFFER_SIZE;//傳送過來總的串列埠資料位元組數 DWORD bytesRead = 0;//當前接收資料位元組數 char commBuff[COMMBUFFER_SIZE];//串列埠資料儲存 DWORD dwError; COMSTAT comstat; DWORD Flag=0; OVERLAPPED ReadOver; memset(&ReadOver,0x00,sizeof(OVERLAPPED)); ReadOver.Internal=0
; ReadOver.InternalHigh=0; ReadOver.Offset=0; ReadOver.OffsetHigh=0; ReadOver.hEvent = CreateEventW(NULL,TRUE,FALSE,NULL); CRITICAL_SECTION section; InitializeCriticalSection(&section); //獲取對話方塊類的指標 CDetectionCarDoorDlg* pWnd = (CDetectionCarDoorDlg*)lpParam; while( g_bThreadRun ) { bResult = WaitCommEvent( g_hComm, &dwEvtMask, &ReadOver); if(!bResult) { switch( dwError = GetLastError() ) { case ERROR_IO_PENDING: Flag ^= 1; break; default: Flag=0; PurgeComm(g_hComm,PURGE_TXABORT | PURGE_TXCLEAR | PURGE_RXABORT | PURGE_RXCLEAR); continue; } }else { bResult=ClearCommError(g_hComm,&dwError,&comstat); if(comstat.cbInQue==0) continue; } if( Flag & 1 ) { WaitForSingleObject(ReadOver.hEvent,INFINITE);///等待非同步操作完成 } Flag=0; GetCommMask( g_hComm,&dwEvtMask); if( ( dwEvtMask & EV_RXCHAR) == EV_RXCHAR ) { EnterCriticalSection(&section); memset(commBuff,0,COMMBUFFER_SIZE*sizeof(char) ); ClearCommError(g_hComm, &dwError, &comstat); if (comstat.cbInQue == 0) continue; bResult = ReadFile( g_hComm, // Handle to COMM port commBuff, // RX Buffer Pointer bytesComm, // Read bytes &bytesRead, // Stores number of bytes read &ReadOver); // pointer to the m_ov structure if( !bResult ) { switch( dwError = GetLastError() ) { case ERROR_IO_PENDING: Flag ^= 1; break; default: Flag=0; PurgeComm( g_hComm,PURGE_TXABORT | PURGE_TXCLEAR | PURGE_RXABORT | PURGE_RXCLEAR ); continue; } } if(Flag & 1) { WaitForSingleObject( ReadOver.hEvent, INFINITE ); GetOverlappedResult( g_hComm,&ReadOver, &bytesRead,TRUE ); } //資料解析 pWnd->getData(commBuff, bytesRead); LeaveCriticalSection( &section ); } } return 0; } bool openPort() { `````````(建立串列埠控制代碼及設定各類引數,可參考https://blog.csdn.net/sazass/article/details/82259616) //設定事件 bool portStat = SetCommMask(g_hComm, EV_RXCHAR); if (!portStat) { AfxMessageBox(L"串列埠事件設定失敗"); return false; } ````````` } //把串列埠的char* 型別轉換成其他型別(CString) void getData(char* commBuff, int bytesRead) { int nDataFirstLength = 0; nDataFirstLength = bytesRead; memset(m_receive, 0, (COMMBUFFER_SIZE + 1)*sizeof(char)); memcpy(m_receive, commBuff, nDataFirstLength); CString strData; strData = CString(m_receive); //清除緩衝區 PurgeComm(g_hComm, PURGE_TXCLEAR | PURGE_RXCLEAR | PURGE_RXABORT | PURGE_TXABORT); }

相關推薦

串列埠通訊-----串列埠監聽執行緒全域性函式(C++)

``````` #include "windows.h" #define COMMBUFFER_SIZE 18 //每組資料位元組數 //串列埠變數 HANDLE g_hComm = INVALID_HANDLE_VALUE;//串列埠控制代碼 HANDLE g_hCommThread = NU

監聽執行緒的執行結果繼續執行

 背景：有兩臺電腦A,B 欄位filed：A電腦中的狀態欄位（初始為false）； 執行緒t1：執行在A電腦，時刻監聽欄位filed的狀態，當filed為true的時候，然後進行操作再將filed設定為false； url1：電腦B呼叫電腦A中的方法，改變field的狀態(filed改變為tr

Delphi使用SPCOMM串列埠通訊 串列埠號大於10出錯的解決辦法

用Delphi 7.0編寫串列埠讀寫程式，發現有些串列埠無法開啟，打開出錯。“Error opening serial port”。 經過百度查詢有參考文章解決，複製內容過來如下： 如果你已經會使用SPCOMM且出現10個以上的串列埠問題 請改一下串列埠名

Android串列埠通訊:串列埠讀寫

公司有個專案要用到串列埠通訊，同事有寫好一個DEMO，用的時候發現會有問題，從jni讀串列埠資料時，經常會被截斷，修改select延時還是無濟於事，於是想到用JAVA直接去讀/寫串列埠檔案，經過搜尋在iteye上的一篇部落格1可以滿足需求，但看到下面留言說有問題

Delphi使用spcomm串列埠通訊 串列埠號大於10出錯的解決辦法 spcomm error opening serial port

//./com18是windows裡邊的SymbolLinkName，這個在WINAPI裡邊就需要這 樣寫，SPCOMM的這部分的原始碼如下： procedure TComm.StartComm; var    hNewCommFile:   THandle; begin      // Are w

程序間，執行緒間的通訊方式及程序與執行緒的區別

近日想總結下程序間，執行緒間的通訊方式，在網上搜索了下，感覺寫的很好，照搬過來，當做加深記憶。 幾種程序間的通訊方式 （1） 管道（pipe）：管道是一種半雙工的通訊方式，資料只能單向流動，而且只能在具有血緣關係的程序間使用。程序的血緣關係通常指父子程序關係。 （2）有名管道（named p

Linux 學習筆記—執行緒間通訊的概念和執行緒控制函式

1 執行緒間通訊 執行緒間無需特別的手段進行通訊，由於執行緒間能夠共享資料結構，也就是一個全域性變數能夠被兩個執行緒同一時候使用。只是要注意的是執行緒間須要做好同步，一般用mutex。執行緒間的通訊目的主要是用於執行緒同步，所以執行緒沒有像程序通訊中的用於資料交

（轉）jquery 監聽div大小變化函式|div resize事件

https://blog.csdn.net/mengzhengjie/article/details/72829828  （原文連結）   視窗有大小改變的監聽事件，卻不適用於div window.onresize = function(){}  

java socket通訊I/O阻塞>多執行緒實現非阻塞通訊

簡單的java socket通訊，多個客戶端同時連線，功能可在此基礎上進行擴充套件。效果如圖： server： package com.lb.LB_Socket; import java.io.BufferedReader; import ja

多執行緒通訊（三）多執行緒通知/等待交叉進行

        如何向A、B兩個檔案中寫資料並且向A、B中寫資料是交叉進行的，假定向A中寫資料的是A執行緒，向B中寫資料的是B執行緒，那麼可以通過定義一個標識，用來控制A、B執行緒的交叉效果。定義輸出類public class FileOutput { // 定義v

wait/notify 方法執行緒間的通訊,只隨機通知一個執行緒進行喚醒,一次性喚醒所有執行緒， wait(long) 的使用，通知過早會打亂順序正常的邏輯順序

一.wait()、notify()和notifyAll() 　　wait()、notify()和notifyAll()是Object類中的方法： 1 2 3 4 5 6 7 8 9 10

C/C++程式設計教訓----函式內靜態類物件初始化非執行緒安全（C++11之前）

不少程式設計師在編寫程式的時候，會使用函式內靜態(static)變數，既能滿足函式內這個變數可以持久的記錄某些資訊，又使其訪問範圍的控制侷限於函式內。但函式內靜態類物件初始化是非執行緒安全的。 問題背景 在我們產品中對log4cxx做了一些簡單的封裝 （採用VS2005編譯），其中會

筆記：Java實現三個執行緒A B C，BC執行緒執行完再執行A線

final Lock lc = new ReentrantLock(); .. run() { lc.lock(); ... lc.unlock(); } 可能開啟方式不對吧,沒實現！ 改用join() 可以實現(BC與A以單執行緒模式執行)，程式碼如下： package

執行緒建立函式pthread_create的引數解析

int pthread_create(pthread_t *thread, const pthread_attr_t *attr,void *(*start_routine) (void *), void *arg);   void *(*start_routine) (void

配置查詢與執行緒追蹤函式|全方位認識 sys 系統庫

不知不覺中，我們的"全方位認識 sys 系統庫" 系列文章已經接近尾聲了，在上一篇《字串與數字轉換函式|全方位認識 sys 系統庫》中，我們介紹了sys 系統庫中用於字串和數字格式化轉換的函式，本期的內容給大家介紹 sys 系統庫中的剩餘函式，這也是本系列文章的最後一篇。 PS：下文中如果函式定

strongswan——執行緒處理函式

1. 將函式壓入當前執行緒的清理處理程式棧中。 每當執行緒被取消、退出或使用TRUE作為執行引數呼叫thread_cleanup_pop函式時都會呼叫回撥函式cleanup。 void thread_cleanup_push(thread_cleanup_t cleanup, void *arg); 其中

建立ABC三條執行緒 保證 A執行緒 列印 我 B執行緒列印愛 C執行緒 列印你 如此需要 10個我愛你

public class DoSome implements Runnable{ //三個變數 三條執行緒之間切換執行 一把鎖是不夠的 2把鎖把鎖 物件有鎖的定義 Object物件 private String word;//執行緒要列印的字

GIL執行緒全域性鎖

1.GIL概述 GIL ( Global Interperter Lock ) 稱作全域性直譯器鎖。首先需要明確一點，我們所講的 GIL 並不是 Python 語言的特性，它是在實現 Python 直譯器時引用的一個概念。GIL 只在CPython 直譯器上存在。 2.GIL優缺點 優點

多執行緒相關函式歸納

多執行緒相關函式必備標頭檔案： #include <pthread.h> #include <semaphore.h> Linux 的執行緒是通過使用者級的函式庫實現的，一般採用 pthread 執行緒庫實現執行緒的訪問和控制。它用第

C++多執行緒系列（C++11）-uniqu_lock（四）

Data 2018/11/12 Add By  WJB 在多執行緒中，有時候會出現一個方法中又一斷或者多段程式碼需要加鎖，但是並非整個方法程式碼加鎖，那麼我們就需要一個靈活的鎖-unique_lock;說明：unique_lock會降低程式碼執行效率，不推薦使用。 我們接