Форум программистов, компьютерный форум, киберфорум
C# .NET
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.77/22: Рейтинг темы: голосов - 22, средняя оценка - 4.77
1 / 1 / 0
Регистрация: 31.01.2013
Сообщений: 37

SerialPort: Ожидание События или получение ответа из потока чтения флуда байтов

07.12.2013, 00:33. Показов 4819. Ответов 2
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Имеется:
OpenPort() - открывает порт и любимый Поток
readport() - Поток который считывает всё, всегда и везде
lan() - метод который требует ответа, и чтобы все остальное запаузилось, пока не получит ответа
main() - запускает все это

Источник входящих байтов (ответов) - огромный постоянный нескончаемый поток флуда(т.е. байтов),
среди которого требуется получить быстрый и точный ответ на одну операцию.
я не знаю, как сделать ожидание ответа (чтобы все остальное запаузилось, пока не получу) в потоке,
поэтому решил сделать по-простому: написать в порт и сразу считать из него, запаузив поток чтения.

Проблема:
TimeoutException
по абсолютному рандому(50 на 50) я получаю TimeoutException.
причем я вижу по Serial Port Monitor'у, что ответ пришел и его считали(раз я увидел, что он пришел).
А ГЛАВНОЕ, когда в дебагере прогоняю: ответ ВСЕГДА получаю. таймауты у меня большие сами увидите
у меня все подозрения на поток, что он считывает не должное ему.
как с ним обойтись?
Abort()'ом может? правда доступа к потоку нету, чтобы запустить новый, придется дописывать...
или как вообще грамотно организовать всю эту ситуацию?

Вопрос: возможно ли сделать ожидание события? типо Sleep() в методе lan(), только чтобы разбудить (дождаться ответа) из readport()?

C#
1
2
3
4
5
6
7
8
9
10
 public void Main()
 {
     Data.stopread = false; //разрешаем потоку считывать байты
     foo[2] = lan; //массив методов. не суть
     OpenPort(); //открывается поток постоянного чтения всего и вся
     foreach (MyDelegate f in foo)
     {
     f();
     }
 }
C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
    public bool OpenPort() // см. Main()
    {            
 
        if (port.IsOpen)
        {
            MessageBox.Show(port.PortName + " уже открыт");
            return false;
        }
        try
        {
            port.Open();
        }
        catch (Exception ex)
        {
            MessageBox.Show(ex.Message + "\n(Порт " + port.PortName + " не доступен.");
            return false;
        }
        threadport = new Thread(readport); //вот
        threadport.IsBackground = true;
        threadport.Start();    
 
        return true;
    }
C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
    public void readport()  //поток; см. OpenPort()
    {            
        while (port.IsOpen)
        {
            if (!Data.stopread) //в любой момент можем прикрыть читалку, вроде как?
            {
                Thread.Sleep(500); //каждые пол секунды выдаем, всё, что насобирали
                try
                {
                    if (port.BytesToRead > 0)
                    {
            string hex = "";
                        int gotbytes = port.BytesToRead; 
                       
                        for (int i = 0; i < gotbytes; i++) 
                        {
                            int dec = port.ReadByte();
                            var msg = dec.ToString("X");
                            if (msg.Length < 2) msg = "0" + msg;
                            hex += " " + msg;
                        }
 
                        string answer = Data.pred_answer + hex;
                        if (answer.Length >= 15) //из всего потока байтов выискиваем те, что несут, хоть какой-то смысл
                        {
                            if (find(answer, "64 32 05 DF 4E", hex, out hex)) Invoke(new EventHandler(delegate { textBox1.AppendText("PASS comand" + Environment.NewLine); }));
                            if (find(answer, "64 32 0C 9F CA", hex, out hex)) Invoke(new EventHandler(delegate { textBox1.AppendText("NOT Correct comand" + Environment.NewLine ); }));
                            if (find(answer, "64 32 0B 8F EB", hex, out hex)) Invoke(new EventHandler(delegate { textBox1.AppendText("CRC16 FAILED" + Environment.NewLine ); }));
                        }                       
                        Invoke(new EventHandler(delegate { textBox3.AppendText("TV: " + hex + Environment.NewLine + Environment.NewLine); }));
                    }
                }
                catch (ThreadAbortException) { }   //это исключение появится при аборте
                catch (IOException) { }        
                catch (TimeoutException) { }
                catch (Exception)
                {
                    //continue;
                }
            }
        }
    }
C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
    public bool lan() // см. Main
    {            
    SerialPort port = new SerialPort(); // с ним имеем дело
        Data.stopread = true; //вроде как остановил поток чтения байтов по порту
 
        port.DiscardInBuffer();  //очистил все лишнее, что могло набежать
          
        port.ReadTimeout = 2000; // устанавливаем таймаут
 
        string fail = "11 11 11 11 11 11 11 11 11 11 11";
        string success = "AA AA AA AA AA AA AA AA AA AA AA";
        byte[] answer = new byte[11];
        string str_answer = "";
 
        port.Write(send, 0, send.Length); //послали запрос. не суть
 
        Thread.Sleep(1000); //даем время, чтобы пришли байты/ответ (очень даже много)
 
        try
        {            
            for (int i = 0; i < 11; i++)
            {
                int dec = port.ReadByte(); //читаем первых 11 байт
                var msg = dec.ToString("X");
                if (msg.Length < 2) msg = "0" + msg;
                str_answer += " " + msg;
            }
        }
        catch (TimeoutException)
        {
            txtbox.code_write(" НЕТ ОТВЕТА LAN");
            return false;
        }
 
        // if (str_answer == fail) //deleted
        if (str_answer == success)
        {
            txtbox.code_write("LAN OK");
            Data.stopread = false; //возвращаем поток к жизни - чтению всего и вся (байтов)
            return true;
        }
        txtbox.code_write("LAN: undefined answer");
        Data.stopread = false;  //возвращаем поток к жизни - чтению всего и вся (байтов)           
        return false;
    }
0
Programming
Эксперт
39485 / 9562 / 3019
Регистрация: 12.04.2006
Сообщений: 41,671
Блог
07.12.2013, 00:33
Ответы с готовыми решениями:

Сокеты(отправка байтов серверу и получение ответа)
Нужна книга,в которой будет подробно описана работа с сокетами,т.е добавление байтов CUint и т.д. Очень нужна. Дайте ссылку на...

Вызов функции другого потока и получение ответа с наименьшим кол-вом строк кода [QueuedConnection]
В общем, предположим есть два объекта классов GUIBackEnd и Processor, работающих в разных потоках. Допустим, в классе GUIBackEnd есть...

Передать массив байтов в SerialPort
Здравствуйте, суть такова, по нажатии на кнопку должен передаться в COM порт байтовый массив на Atmega16, но он передается как бы со...

2
13 / 13 / 2
Регистрация: 21.08.2012
Сообщений: 66
07.12.2013, 01:30
Sleep не используется для синхронизации потоков, это плохая практика. Потому что очерёдность выполнения не предсказуема.

Добавлено через 1 минуту
Попробуйте http://msdn.microsoft.com/ru-r... .110).aspx
Wait ожидание Set.

Добавлено через 6 минут
Метод Wait() усыпляет текущий поток до момента Set().
Всего их WaitHandle-ов может быть в районе 60. Есть ещё SpinLock http://msdn.microsoft.com/ru-r... .110).aspx

Насколько я помню WaitHandle это синхронизация режима ядра(тяжёлые)
SpinLock легче, но постоянная проверка это процессорное время.
1
 Аватар для Spectral-Owl
608 / 583 / 157
Регистрация: 29.06.2010
Сообщений: 1,620
09.12.2013, 09:37
Цитата Сообщение от Referal Посмотреть сообщение
var msg = dec.ToString("X");
if (msg.Length < 2) msg = "0" + msg;
C#
1
var msg = dec.ToString("X2");
а ещё мне кажется что слип там действительно нафиг не нужен, т.к. в точке port.ReadByte() стим будет ожидать пока не прочитается какой-нибудь байт, а прервётся это ожидание либо при аборте потока, либо при тайм-ауте. соответственно цикл тоже не нужен, как и проверка на то, сколько байт доступно портом для чтения. просто до тайм-аута собирать байтики в кучу, а во время - уже проверка на то чтоб их небыло 0, и выдача. ну это так, один из вариантов, может с ним проблем будет меньше.

Добавлено через 1 минуту
Цитата Сообщение от Referal Посмотреть сообщение
catch (TimeoutException) { }
Цитата Сообщение от Referal Посмотреть сообщение
catch (TimeoutException) { txtbox.code_write(" НЕТ ОТВЕТА LAN"); return false; }
мне кажется что здесь избыточность
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
inter-admin
Эксперт
29715 / 6470 / 2152
Регистрация: 06.03.2009
Сообщений: 28,500
Блог
09.12.2013, 09:37
Помогаю со студенческими работами здесь

Отправить массив байтов в SerialPort
Здравствуйте, суть такова, по нажатии на кнопку должен передаться в COM порт байтовый массив, но он передается как бы со второго раза....

Сканирование байтов в памяти, и получение начального адреса байтов
Привет форумчане! У меня вопрос, как просканировать память у процесса так, чтобы получить адрес начала байтов в памяти? Я попробовал...

c# SerialPort.ReadExisting Чтение байтов из последовательного порта
Доброе время суток. Подскажите пожалуйста каким образом используя SerialPort.ReadExisting прочитать данные из порта в формате байтов. На...

Организовать приём байтов из буфера последовательного порта SerialPort
Всем здравствуйте. Подскажите, пожалуйста, кто работал с последовательным портом, как правильно организовать приём байтов из буфера...

SerialPort. Отсутствие ответа от конкретного устройства
Доброго времени суток! Сложилась такая ситуация Есть термоизмеритель CENTER 306 на интерфейсе RS-232, подключен через USB-SERIAL, если...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
3
Ответ Создать тему
Новые блоги и статьи
SDL3 для Web (WebAssembly): Обработчик клика мыши в браузере ПК и касания экрана в браузере на мобильном устройстве
8Observer8 02.02.2026
Содержание блога Для начала пошагово создадим рабочий пример для подготовки к экспериментам в браузере ПК и в браузере мобильного устройства. Потом напишем обработчик клика мыши и обработчик. . .
Философия технологии
iceja 01.02.2026
На мой взгляд у человека в технических проектах остается роль генерального директора. Все остальное нейронки делают уже лучше человека. Они не могут нести предпринимательские риски, не могут. . .
SDL3 для Web (WebAssembly): Вывод текста со шрифтом TTF с помощью SDL3_ttf
8Observer8 01.02.2026
Содержание блога В этой пошаговой инструкции создадим с нуля веб-приложение, которое выводит текст в окне браузера. Запустим на Android на локальном сервере. Загрузим Release на бесплатный. . .
SDL3 для Web (WebAssembly): Сборка C/C++ проекта из консоли
8Observer8 30.01.2026
Содержание блога Если вы откроете примеры для начинающих на официальном репозитории SDL3 в папке: examples, то вы увидите, что все примеры используют следующие четыре обязательные функции, а. . .
SDL3 для Web (WebAssembly): Установка Emscripten SDK (emsdk) и CMake для сборки C и C++ приложений в Wasm
8Observer8 30.01.2026
Содержание блога Для того чтобы скачать Emscripten SDK (emsdk) необходимо сначало скачать и уставить Git: Install for Windows. Следуйте стандартной процедуре установки Git через установщик. . . .
SDL3 для Android: Подключение Box2D v3, физика и отрисовка коллайдеров
8Observer8 29.01.2026
Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами. Версия v3 была полностью переписана на Си, в. . .
Инструменты COM: Сохранение данный из VARIANT в файл и загрузка из файла в VARIANT
bedvit 28.01.2026
Сохранение базовых типов COM и массивов (одномерных или двухмерных) любой вложенности (деревья) в файл, с возможностью выбора алгоритмов сжатия и шифрования. Часть библиотеки BedvitCOM Использованы. . .
SDL3 для Android: Загрузка PNG с альфа-каналом с помощью SDL_LoadPNG (без SDL3_image)
8Observer8 28.01.2026
Содержание блога SDL3 имеет собственные средства для загрузки и отображения PNG-файлов с альфа-каналом и базовой работы с ними. В этой инструкции используется функция SDL_LoadPNG(), которая. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru