Обмен данными между потоками

@super1337coder · Регистрация: 18.02.2014

Студворк — интернет-сервис помощи студентам

Здравствуйте уважаемые форумчане!
Реализую многопоточное приложение. Один поток в реальном времени читает данные с USB и пишет их в массив (массив большой, 256*65536), второй должен эти данные обрабатывать (нарезать на другие массивы, поменьше, что-то делать с ними, результат складывать в финальный массив), третий занимается тем, что выводит финальный массив на Panel. Потоки делаю не CreateThread, а TThread, ради VCL-компонентов.
Вопрос вот в чем: как реализовать обмен данными между потоками? Иными словами, как первый большой массив передать из 1го потока во 2ой и как передать последний массив из 2го потока в 3й? С классами на данный момент знаком очень поверхностно, раньше только с функциями работал.
Заранее спасибо за помощь!

@gumi250 · 20.02.2014, 15:09

Сообщение от Avazart

Для академичекого интереса лучше книги почитать.

Теория без практики мертва

Сообщение от Avazart

Цитата Сообщение от gumi250 Посмотреть сообщение
Причем подразумевается что прцесс чтения быстрее записи.
C потоками такие допущения делать нельзя.

Никак иначе быть не может, данные должны обрабатывать быстрее чем их получают, иначе их некуда будет девать.

Сообщение от Avazart

Как это меняет дело?

2 общих буффера, 2 общих флага-переменных bool f1, f2. Перед началом записи в 1ый буфер первый поток делает f1=true, по окнчании записи делает f1=false.Для второго буффера аналогично, но с флагом f2. Второй поток в ожидании крутит цикл и ждет когда настанет !f1 или !f2 чтобы начать чтение из соответствующего буфера. Как тут может возникнуть чтение кривых данных?

@Avazart · 20.02.2014, 15:57

Сообщение от gumi250

Никак иначе быть не может, данные должны обрабатывать быстрее чем их получают, иначе их некуда будет девать.

То как должно быть, но то как есть...
Собственно это и нужно обеспечить программисту.

Сообщение от gumi250

2 общих буффера, 2 общих флага-переменных bool f1, f2.

Сообщение от gumi250

Как тут может возникнуть чтение кривых данных?

bool не атомарный тип данных,точнее сказать нет гаранитии что операции над bool атомарны.
Переменная bool так же разделяемая ресурс, как и другие данные.

Сообщение от gumi250

Второй поток в ожидании крутит цикл и ждет когда настанет !f1 или !f2 чтобы начать чтение из соответствующего буфера. Как тут может возникнуть чтение кривых данных?

Про "кручения в цикле" вообще молчу ...

Не по теме:

Любители поучить плохому ...

@SatanaXIII · 20.02.2014, 16:04

Avazart, вы сами почитайте, что я пишу. Я же вам говорю, что да, правильно делать синхронизацию не костылями, а проверенными методами. Кто спорит? Но так же говорю, что можно (я не выставляю это как какую-то безоговорочную истину) реализовать синхронизацию своими руками. Вы чуете разницу или опять не чуете? А конкретнее через выставление флага окончания работы с разделяемыми данными ~~(хоть булевого, хоть бит какой-нибудь изменять по определенному адресу, чтобы влезло в такт)~~. Даже не нужно запариваться с атомарностью - первый поток закончил работу с данными, выставил флаг "Я закончил", второй поток постоянно смотрит на флаг первого, и хоть тот ему будет черта лысого показывать, хоть анекдоты травить, пока не увидит четкого "Я закончил" к данным не притронется. Порченные, некорректные кто? Флаги? Наплевать. Данные? Зачем поток будет портить данные во время работы? А другие к нему не сунутся, так как флаги. И где что порченное? О чем вы?
Прекратите читать то, что вы хотите видеть - читайте, что до вас пытаются донести.

@Avazart · 20.02.2014, 16:15

Сообщение от SatanaXIII

Прекратите читать то, что вы хотите видеть - читайте, что до вас пытаются донести.

Ну так что я предложил использовать bool для синхронизации?
Или я ввел неуместный термин "флаг" ?

Сообщение от SatanaXIII

Avazart, вы сами почитайте, что я пишу. Я же вам говорю, что да, правильно делать синхронизацию не костылями, а проверенными методами. Кто спорит? Но так же говорю, что можно (я не выставляю это как какую-то безоговорочную истину) реализовать синхронизацию своими руками.

Не смущает что "правильно" и "можно", взаимоисключающие понятия ?
Можно вообще синхронизацию не делать пусть падает приложение... пользователь всегда сможет его еще раз запустить...

@gumi250 · 20.02.2014, 16:22

Сообщение от Avazart

bool не атомарный тип данных

Атомарность важна при работе с многобайтовыми перенными. Например флоат. Пока второй поток читает 4 байта, первый поток может изменить их. Т.е. второй поток может получить первые 2 байта от одного числа вторые 2 байта от другого числа, и как результат получит треть число. У нас переменная bool, т.е. занимает 1 байт. И даже в этот байте нас интерисует только 1 бит, 0 он или 1. Изменить 1 бит в процессе его чтения на другое значение, чтобы получилось треть значение бита не реально. Чем это не атомарность?

Сообщение от Avazart

Про "кручения в цикле" вообще молчу ...

Я же сразу сказал, что это проблема. Но если флаг меняется не часто, то вставляем в цикл Sleep(1) и все нормально.

Сообщение от SatanaXIII

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

Нормально нельзя. В дом можно и через окно залезть, но это не нормально.

@Avazart · 20.02.2014, 16:25

Сообщение от gumi250

Атомарность важна при работе с многобайтовыми перенными. Например флоат. Пока второй поток читает 4 байта,

Сообщение от gumi250

У нас переменная bool, т.е. занимает 1 байт.

Так а какие гарантии что bool не реализован через int ?

@gumi250 · 20.02.2014, 16:31

Сообщение от Avazart

Так а какие гарантии что bool не реализован через int ?

1. Нам все равно нужен только один бит. Остальные биты будут нулями, т.к. ничто иное в них не пишут, да мы их и не смотрим.
2. Можно взять BYTE, и смотреть в нем 1 бит.

@Avazart · 20.02.2014, 16:39

Ну так сегодня нам нужен один бит, завтра два итд.

Сообщение от gumi250

2. Можно взять BYTE, и смотреть в нем 1 бит.

Уверен ?
С++ нет такого типа данных...

@gumi250 · 20.02.2014, 16:43

В билдере есть. Это ведь форум билдера. Можно char сути это не меняет.

@Avazart · 20.02.2014, 17:02

Сообщение от gumi250

В билдере есть. Это ведь форум билдера. Можно char сути это не меняет.

Уверен? Билдер что не в плюсовом разделе находится?
BYTE это скорее typedef какого нибудь плюсового типа, в XE3 это:

C++
1
typedef unsigned char       BYTE;

Но не факт что в другой среде будет другой тип данных и соответственно нежданчик...

Но допустим проехали этот момент... возьмемся за другой ...
Кто гарантирует что ваш char не оптимизируется компилятором и вы не получите "чудо-сюрприз" ?

http://mainloop.ru/c-language/... atile.html

Я к тому что ваши ручные методы не всегда соответствуют вашим ожиданиям, ну и знаниям в данном вопросе если говорить о теории.
Если у вас куча времени на отладку программ и выяснение таких вещей на практике, что же это ваш выбор...

Так спрашивается стоит ли так извращаться? или проще сразу отмести такой ручной вариант и использовать стандартные, предусмотренные для этого подходы?

Добавлено через 6 минут
Что касается флагов, то как пишут можно полагаться на атомарность:

C++
1
volatile unsigned char

Новые блоги и статьи Все статьи Все блоги /
Очистка реквизитов документа при копировании Maks 09.04.2026 Алгоритм из решения ниже применим как для типовых, так и для нетиповых документов на самых различных конфигурациях. Задача: при копировании документа очищать определенные реквизиты и табличную. . .	модель ЗдравоСохранения 8. Подготовка к разному выполнению заданий anaschu 08.04.2026 https:/ / github. com/ shumilovas/ med2. git main ветка * содержимое блока дэлэй из старой модели теперь внутри зайца новой модели 8ATzM_2aurI	Блокировка документа от изменений, если он открыт у другого пользователя Maks 08.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа, разработанного в конфигурации КА2. Задача: запретить редактирование документа, если он открыт у другого пользователя. / / . . .	Система безопасности+живучести для сервера-слоя интернета (сети). Двойная привязка. Hrethgir 08.04.2026 Далее были размышления о системе безопасности. Сообщения с наклонным текстом - мои. А как нам будет можно проверить, что ссылка наша, а не подделана хулиганами, которая выбросит на другую ветку и. . .
Модель ЗдрввоСохранения 7: больше работников, больше ресурсов. anaschu 08.04.2026 работников и заданий может быть сколько угодно, но настроено всё так, что используется пока что только 20% kYBz3eJf3jQ	Дальние перспективы сервера - слоя сети с космологическим дизайном интефейса карты и логики. Hrethgir 07.04.2026 Дальнейшее ближайшее планирование вывело к размышлениям над дальними перспективами. И вот тут может быть даже будут нужны оценки специалистов, так как в дальних перспективах всё может очень сильно. . .	Горе от ума kumehtar 07.04.2026 Эта мне ментальная установка, что вот прямо сейчас, мол, мне для полного счастья не хватает (нужное вписать), и когда я этого достигну - тогда и полный кайф. Одна из самых сильных ловушек на пути. . . .	Использование значений реквизитов справочника в документе, с определенными условиями и правами Maks 07.04.2026 1. Контроль срока действия договора Алгоритм из решения ниже реализован на примере нетипового документа "ЗаявкаНаРаботу", разработанного в конфигурации КА2. Задача: уведомлять пользователя, если. . .

@super1337coder 0 / 0 / 0 Регистрация: 18.02.2014 Сообщений: 5

	Обмен данными между потоками 18.02.2014, 17:59. Показов 13213. Ответов 29 Метки нет (Все метки) Здравствуйте уважаемые форумчане! Реализую многопоточное приложение. Один поток в реальном времени читает данные с USB и пишет их в массив (массив большой, 256*65536), второй должен эти данные обрабатывать (нарезать на другие массивы, поменьше, что-то делать с ними, результат складывать в финальный массив), третий занимается тем, что выводит финальный массив на Panel. Потоки делаю не CreateThread, а TThread, ради VCL-компонентов. Вопрос вот в чем: как реализовать обмен данными между потоками? Иными словами, как первый большой массив передать из 1го потока во 2ой и как передать последний массив из 2го потока в 3й? С классами на данный момент знаком очень поверхностно, раньше только с функциями работал. Заранее спасибо за помощь! 0

@SatanaXIII Почетный модератор 5851 / 2862 / 392 Регистрация: 01.11.2011 Сообщений: 6,906
	20.02.2014, 16:04
	Avazart, вы сами почитайте, что я пишу. Я же вам говорю, что да, правильно делать синхронизацию не костылями, а проверенными методами. Кто спорит? Но так же говорю, что можно (я не выставляю это как какую-то безоговорочную истину) реализовать синхронизацию своими руками. Вы чуете разницу или опять не чуете? А конкретнее через выставление флага окончания работы с разделяемыми данными ~~(хоть булевого, хоть бит какой-нибудь изменять по определенному адресу, чтобы влезло в такт)~~. Даже не нужно запариваться с атомарностью - первый поток закончил работу с данными, выставил флаг "Я закончил", второй поток постоянно смотрит на флаг первого, и хоть тот ему будет черта лысого показывать, хоть анекдоты травить, пока не увидит четкого "Я закончил" к данным не притронется. Порченные, некорректные кто? Флаги? Наплевать. Данные? Зачем поток будет портить данные во время работы? А другие к нему не сунутся, так как флаги. И где что порченное? О чем вы? Прекратите читать то, что вы хотите видеть - читайте, что до вас пытаются донести. 0

@gumi250 435 / 402 / 57 Регистрация: 06.02.2012 Сообщений: 1,384
	20.02.2014, 16:43
	В билдере есть. Это ведь форум билдера. Можно char сути это не меняет. 0