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 对象。

公共方法

名称	说明
ordered_message_processor::async_send 方法	如果尚未异步对消息进行排队和开始处理任务，则完成此操作。（重写 message_processor::async_send。）
ordered_message_processor::initialize 方法	使用相应的回调函数、计划程序和计划组初始化 ordered_message_processor 对象。
ordered_message_processor::initialize_batched_processing 方法	initialize 批处理消息处理
ordered_message_processor::sync_send 方法	如果尚未同步对消息进行排队和开始处理任务，那么完成此操作。（重写 message_processor::sync_send。）
ordered_message_processor::wait 方法	特定于处理器的自旋等待，在消息块的析构函数中使用以确保在销毁块之前有时间完成所有异步方法处理任务。（重写 message_processor::wait。）

受保护的方法

名称	说明
ordered_message_processor::process_incoming_message 方法	异步调用的处理函数。它将消息取消排队，并开始处理它们。（重写 message_processor::process_incoming_message。）

继承层次结构

message_processor

ordered_message_processor

要求

**标头：**agents.h

命名空间: 并发

请参见

参考

concurrency 命名空间