Поделиться через

Класс message_processor

  • Статья

Класс message_processor — это абстрактный базовый класс для обработки объектов message. Упорядочивание сообщений не гарантируется.

Синтаксис

template<class T>
class message_processor;

Параметры

T
Тип данных полезных данных в сообщениях, обрабатываемых этим message_processor объектом.

Участники

Общедоступные определения типов

Имя Описание
type Псевдоним типа для T.

Открытые методы

Имя Описание
async_send При переопределении в производном классе помещает сообщения в блок асинхронно.
sync_send При переопределении в производном классе помещает сообщения в блок синхронно.
ждать При переопределении в производном классе ожидает завершения всех асинхронных операций.

Защищенные методы

Имя Описание
process_incoming_message При переопределении в производном классе выполняет переопределение сообщений в блок. Вызывается один раз при каждом добавлении нового сообщения, и очередь обнаруживается пустой.

Иерархия наследования

message_processor

Требования

Заголовок: agents.h

Пространство имен: concurrency

async_send

При переопределении в производном классе помещает сообщения в блок асинхронно.

virtual void async_send(_Inout_opt_ message<T>* _Msg) = 0;

Параметры

_Msg
Объект message для асинхронной отправки.

Замечания

Реализации процессора должны переопределить этот метод.

process_incoming_message

При переопределении в производном классе выполняет переопределение сообщений в блок. Вызывается один раз при каждом добавлении нового сообщения, и очередь обнаруживается пустой.

virtual void process_incoming_message() = 0;

Замечания

Реализации блока сообщений должны переопределить этот метод.

sync_send

При переопределении в производном классе помещает сообщения в блок синхронно.

virtual void sync_send(_Inout_opt_ message<T>* _Msg) = 0;

Параметры

_Msg
message Объект для синхронной отправки.

Замечания

Реализации процессора должны переопределить этот метод.

wait

При переопределении в производном классе ожидает завершения всех асинхронных операций.

virtual void wait() = 0;

Замечания

Реализации процессора должны переопределить этот метод.

См. также

Пространство имен concurrency
Класс ordered_message_processor