Класс ordered_message_processor
ordered_message_processor является message_processor, позволяющим блокам сообщений обрабатывать сообщения в том порядке, в котором они были получены.
template<
class _Type
>
class ordered_message_processor : public message_processor<_Type>;
Параметры
- _Type
Тип полезных данных сообщений, обработанных обработчиком.
Члены
Общедоступные Typedefs
Имя |
Описание |
---|---|
type |
Псевдоним типа для _Type. |
Открытые конструкторы
Имя |
Описание |
---|---|
Конструктор ordered_message_processor::ordered_message_processor |
Создает объект ordered_message_processor. |
Деструктор ordered_message_processor:: ~ ordered_message_processor |
Уничтожает объект ordered_message_processor. |
Открытые методы
Имя |
Описание |
---|---|
Асинхронно ставит в очередь сообщения и запускает задачу обработки, если это не было сделано уже. (Переопределяет message_processor::async_send.) |
|
Инициализирует объект ordered_message_processor с соответствующей обратного вызова функцией, планировщик и расписание группы. |
|
Метод ordered_message_processor::initialize_batched_processing |
Инициализация обработки пакетных сообщений |
Синхронно ставит в очередь сообщения и запускает задачу обработки, если это не было сделано уже. (Переопределяет message_processor::sync_send.) |
|
Ожидание прокрутки определенного процессора, используемое в деструкторах блоков сообщений, чтобы убедиться, что все задачи асинхронной обработки имеют достаточно времени для окончания перед удалением блока. (Переопределяет message_processor::wait.) |
Защищенные методы
Имя |
Описание |
---|---|
Функция обработки, которая вызывается асинхронно. Удаляет сообщения из очереди и начинает обработку их. (Переопределяет message_processor::process_incoming_message.) |
Иерархия наследования
ordered_message_processor
Требования
Заголовок: agents.h
Пространство имен: concurrency