Синхронизация данных при чтении COM порта

@klynxe · Регистрация: 07.09.2012

Вынес отсюда
Как правильно организовать синхронизацию доступа к данным
У меня есть поток в котором я читаю данные из COM порта

C++

CCriticalSection CriticalSectionGPSPoint;
DWORD __stdcall ReadThread(LPVOID hwnd)
 {
 DWORD iSize;
 char sReceivedChar; //переменная для хранения поступающих символов
String str; //переменная для хранения образующихся из символов строк
while (true) //в бесконечном цикле
{
ReadFile(hCom, &sReceivedChar, 1, &iSize, 0); //считываем из порта поступающие символы
 
if ((int)sReceivedChar == 10) //когда встречается символ конца строки
{
Form1->Memo1->Lines->Add(str); //добавляем новую строку в компонент Memo
 if (str.Pos("RMC")) //смотрим, если в строке содержится последовательность «RMC»
{
CriticalSectionGPSPoint.Lock();
ParseRMC(str);
} //то это необходимая нам строка. Вызываем функцию для ее разбора
 if (str.Pos("GST")) //смотрим, если в строке содержится последовательность «RMC»
{
ParseRMC(str);
CriticalSectionGPSPoint.Unlock();
} //то это необходимая нам строка. Вызываем функцию для ее разбора
str = ""; //очищаем переменную для заполнения ее символами новой строки
}
else
 {
 str = str + sReceivedChar; //если строка еще не сформирована, то просто прибавляем 
//поступающие с порта символы
}
 }
 }

То есть мне приходит из порта набор сообщений в виде строк (+ сколько-то пустых строк), которые я парсю (сообщения RMC, GST обрабатываю, остальное выкидываю)

Однако в парсере я должен записать эти данные в какую-то переменную, которую смогу прочитать другим потоком
Для этого я использую критические секции (Начался набор сообщения, сделал лок, закончился набор сообщения, анлок)
А далее в другом потоке мне их надо как-то прочитать соответственно в нем я также вызываю

C++

1
2
3

CriticalSectionGPSPoint.Lock();
//Читаю данные которые записал в потоке чтения порта
CriticalSectionGPSPoint.Unlock();

И в сумме мне все это дает проблему, что при чтении из порта я получаю кривые сообщения
Вместо
$GPGST,085231.00,0.0000,,,,457720,457720,457720*69
получаю
$GPGST,085233.00,0.0000000000000000000000000000000 000000000000,,,,457726,457777777777777777777777777 77777777777777777777777777777777777777726,457726*6 D
То почему-то читаю некоторые символы по много раз
Хотя данная ошибка не стабильная и может появиться на неопределенное по счету сообщение.
Предполагаю, что в момент, когда я из второго потока делаю Lock() (для чтения данных) и первый поток вынужден ждать, что-то происходит, что в результате я получаю неверное сообщение из порта.
Помогите как правильно синхронизировать чтение из порта?

Опции темы