OK.
Количество потоков в примере я ограничик четырьмя. Все описание основывается на рисунке из первого поста
Глобально переменные...
| Код |
// Массивы объектов "пакет" и "блок" по количеству потоков
const ThreadCnt=4;
Packet packet[ThreadCnt];
Block block[ThreadCnt];
|
Далее на форму выложены компоненты TIdUDPServer в количестве равном количеству потоков, т.е в данном случае 4
Все обработчики OnUDPRead повешаны на следующий код...
| Код |
void __fastcall TMainForm::IdUDPServer1UDPRead(TIdUDPListenerThread *AThread, TBytes AData,
TIdSocketHandle *ABinding)
{
// Идентификатор вызывающего объекта
int idx = IdUDPServer1->Tag;
// Буффер для данных
byte buffer[SIZE];
// Длина полученного пакета
int len = AData.Length;
// Преобразование в массив байт
BytesToRaw(AData, &buffer, len);
// Передаем массив объекту класса Message.
// Внутри производится разбиение сообщения на номер и данные.
// На самом деле внутри могут быть сложные операции, требующие
// определенного времени, поэтому сказать, что поток простаивает нельза
Message message;
message.SetValue(buffer);
// Получаем номер текущего сообщения
int NumberMsg = message.GetNumber();
// Передаем в пакет номер текущего сообщения, тем самым проверяя заполнен пакет или нет.
// Сообщения идут строго по возрастанию номеров, поэтому если номер последнего
// сообщения в пакете больше чем номер текущего сообщения, то пакет считается
// заполненым (true), а текущее сообщение принадлежит следующему пакету.
if(packet[idx].IsFull(NumberMsg))
{
// Пакет заполнен. Записываем пакет в блок.
block[idx].AddPacket(packet[idx]);
// Очищаем содержимое пакета
packet[idx].Clear();
}
// Записываем сообщение в пакет
packet[idx].AddMessage(message);
}
|
Таким образом производится получение и упорядочивание данных для обработки.
Обработка должна производиться параллельно в отдельном потоке.
Вот в том и вопрос как лучше организовать обрабатывающую структуру. Во первых, раз объекты глобальные (понимаю, что плохо, но не понимаю, как в моем случае сделать по другому). Соответственно требуется организовать совместный доступ из разных потоков. Предположим можно будет обойтись критическими секциями. При условии, что в блоке все пакеты также нумерованы, можно конечно вытаскивать из каждого блока по пакету. Затем в этих пакетах (из четырех блоков) искать сообщения с одинаковыми номерами. Но как-то через то место все получается.
В целом я описал структуру довольно подробно. Как бы вы спроектировали архитектуру такой программы. Смотрел в сторону паттернов проектирования. Ничего подходящего не нашел. |
)