ordered_message_processor 类

ordered_message_processor 是允许消息块按接受的顺序处理消息的 message_processor

template<
   class _Type
>
class ordered_message_processor : public message_processor<_Type>;

参数

  • _Type
    处理器处理的消息的负载类型。

成员

公共 Typedefs

Name

说明

type

_Type 的类型别名。

公共构造函数

Name

说明

ordered_message_processor::ordered_message_processor 构造函数

构造 ordered_message_processor 对象。

ordered_message_processor::~ordered_message_processor 析构函数

销毁 ordered_message_processor 对象。

公共方法

Name

说明

ordered_message_processor::async_send 方法

如果尚未异步对消息进行排队和开始处理任务,则完成此操作。 (重写 message_processor::async_send。)

ordered_message_processor::initialize 方法

使用相应的回调函数、计划程序和计划组初始化 ordered_message_processor 对象。

ordered_message_processor::sync_send 方法

如果尚未同步对消息进行排队和开始处理任务,那么完成此操作。 (重写 message_processor::sync_send。)

ordered_message_processor::wait 方法

特定于处理器的自旋等待,在消息块的析构函数中使用以确保在销毁块之前有时间完成所有异步方法处理任务。 (重写 message_processor::wait。)

受保护的方法

Name

说明

ordered_message_processor::process_incoming_message 方法

异步调用的处理函数。 它将消息取消排队,并开始处理它们。 (重写 message_processor::process_incoming_message。)

继承层次结构

message_processor

ordered_message_processor

要求

**标头:**agents.h

命名空间: 并发

请参见

参考

Concurrency 命名空间